···

       
15
       
15
       
 
       
// JetstreamEvent represents an event from the Jetstream firehose

     

       
16
       
16
       
 
       
// Jetstream documentation: https://docs.bsky.app/docs/advanced-guides/jetstream

     

       
17
       
17
       
 
       
type JetstreamEvent struct {

     

       
18
       
18
       
-
       
	Did    string          `json:"did"`

     

       
19
       
19
       
-
       
	TimeUS int64           `json:"time_us"`

     

       
20
       
20
       
-
       
	Kind   string          `json:"kind"` // "account", "commit", "identity"

     

       
21
       
21
       
-
       
	Account *AccountEvent  `json:"account,omitempty"`

     

       
18
       
18
       
+
       
	Did      string         `json:"did"`

     

       
19
       
19
       
+
       
	TimeUS   int64          `json:"time_us"`

     

       
20
       
20
       
+
       
	Kind     string         `json:"kind"` // "account", "commit", "identity"

     

       
21
       
21
       
+
       
	Account  *AccountEvent  `json:"account,omitempty"`

     

       
22
       
22
       
 
       
	Identity *IdentityEvent `json:"identity,omitempty"`

     

       
23
       
23
       
+
       
	Commit   *CommitEvent   `json:"commit,omitempty"`

     

       
23
       
24
       
 
       
}

     

       
24
       
25
       
 
       


     

       
25
       
26
       
 
       
type AccountEvent struct {

     
···

       
34
       
35
       
 
       
	Handle string `json:"handle"`

     

       
35
       
36
       
 
       
	Seq    int64  `json:"seq"`

     

       
36
       
37
       
 
       
	Time   string `json:"time"`

     

       
38
       
38
       
+
       
}

     

       
39
       
39
       
+
       


     

       
40
       
40
       
+
       
// CommitEvent represents a record commit from Jetstream

     

       
41
       
41
       
+
       
type CommitEvent struct {

     

       
42
       
42
       
+
       
	Rev        string                 `json:"rev"`

     

       
43
       
43
       
+
       
	Operation  string                 `json:"operation"` // "create", "update", "delete"

     

       
44
       
44
       
+
       
	Collection string                 `json:"collection"`

     

       
45
       
45
       
+
       
	RKey       string                 `json:"rkey"`

     

       
46
       
46
       
+
       
	Record     map[string]interface{} `json:"record,omitempty"`

     

       
47
       
47
       
+
       
	CID        string                 `json:"cid,omitempty"`

     

       
37
       
48
       
 
       
}

     

       
38
       
49
       
 
       


     

       
39
       
50
       
 
       
// UserEventConsumer consumes user-related events from Jetstream