appview,knotserver,spindle: rework jetstream #480

···

       
52
       
 
       
		return nil, fmt.Errorf("failed to setup enforcer: %w", err)

     

       
53
       
 
       
	}

     

       
54
       
 
       


     

       
55
       
-
       
	err = h.jc.StartJetstream(ctx, h.processMessages)

     

       
56
       
-
       
	if err != nil {

     

       
57
       
-
       
		return nil, fmt.Errorf("failed to start jetstream: %w", err)

     

       
58
       
-
       
	}

     

       
59
       
-
       


     

       
60
       
 
       
	// Check if the knot knows about any Dids;

     

       
61
       
 
       
	// if it does, it is already initialized and we can repopulate the

     

       
62
       
 
       
	// Jetstream subscriptions.

     
···

       
73
       
 
       
		}

     

       
74
       
 
       
	}

     

       
75
       
 
       


     

       
0
       
 
       

     

       
0
       
 
       

     

       
0
       
 
       

     

       
0
       
 
       

     

       
0
       
 
       

     

       
76
       
 
       
	r.Get("/", h.Index)

     

       
77
       
 
       
	r.Get("/capabilities", h.Capabilities)

     

       
78
       
 
       
	r.Get("/version", h.Version)

     

···

       
52
       
 
       
		return nil, fmt.Errorf("failed to setup enforcer: %w", err)

     

       
53
       
 
       
	}

     

       
54
       
 
       


     

       
0
       
 
       

     

       
0
       
 
       

     

       
0
       
 
       

     

       
0
       
 
       

     

       
0
       
 
       

     

       
55
       
 
       
	// Check if the knot knows about any Dids;

     

       
56
       
 
       
	// if it does, it is already initialized and we can repopulate the

     

       
57
       
 
       
	// Jetstream subscriptions.

     
···

       
68
       
 
       
		}

     

       
69
       
 
       
	}

     

       
70
       
 
       


     

       
71
       
+
       
	err = h.jc.StartJetstream(ctx, h.processMessages)

     

       
72
       
+
       
	if err != nil {

     

       
73
       
+
       
		return nil, fmt.Errorf("failed to start jetstream: %w", err)

     

       
74
       
+
       
	}

     

       
75
       
+
       


     

       
76
       
 
       
	r.Get("/", h.Index)

     

       
77
       
 
       
	r.Get("/capabilities", h.Capabilities)

     

       
78
       
 
       
	r.Get("/version", h.Version)