| 22 | var ErrStubNetworkServiceWaitInboxNotImplemented = errors.New("stub network service WaitInbox not implemented") |
| 23 | |
| 24 | type StubNetworkStore struct { |
| 25 | ResolveDirectRoomFn func(context.Context, store.NetworkDirectRoomEntry) (store.NetworkDirectRoomSummary, error) |
| 26 | WriteConversationMessageFn func( |
| 27 | context.Context, |
| 28 | store.NetworkConversationMessage, |
| 29 | ) (store.NetworkConversationWriteResult, error) |
| 30 | ListThreadsFn func( |
| 31 | context.Context, |
| 32 | store.NetworkChannelRef, |
| 33 | store.NetworkThreadQuery, |
| 34 | ) ([]store.NetworkThreadSummary, error) |
| 35 | GetThreadFn func(context.Context, store.NetworkChannelRef, string) (store.NetworkThreadSummary, error) |
| 36 | ListDirectRoomsFn func( |
| 37 | context.Context, |
| 38 | store.NetworkChannelRef, |
| 39 | store.NetworkDirectRoomQuery, |
| 40 | ) ([]store.NetworkDirectRoomSummary, error) |
| 41 | ListThreadParticipantsFn func( |
| 42 | context.Context, |
| 43 | store.NetworkChannelRef, |
| 44 | string, |
| 45 | ) ([]store.NetworkThreadParticipant, error) |
| 46 | UpdateNetworkThreadPeerTokenStatsFn func(context.Context, store.NetworkThreadPeerTokenStatsUpdate) error |
| 47 | ListNetworkThreadPeerTokenStatsFn func( |
| 48 | context.Context, |
| 49 | store.NetworkThreadPeerTokenStatsQuery, |
| 50 | ) ([]store.NetworkThreadPeerTokenStats, error) |
| 51 | GetDirectRoomFn func( |
| 52 | context.Context, |
| 53 | store.NetworkChannelRef, |
| 54 | string, |
| 55 | ) (store.NetworkDirectRoomSummary, error) |
| 56 | ListConversationMessagesFn func( |
| 57 | context.Context, |
| 58 | store.NetworkConversationRef, |
| 59 | store.NetworkConversationMessageQuery, |
| 60 | ) ([]store.NetworkConversationMessage, error) |
| 61 | GetWorkFn func(context.Context, string, string) (store.NetworkWorkEntry, error) |
| 62 | GetNetworkChannelFn func(context.Context, store.NetworkChannelRef) (store.NetworkChannelEntry, error) |
| 63 | ListNetworkChannelsFn func(context.Context, store.NetworkChannelQuery) ([]store.NetworkChannelEntry, error) |
| 64 | WriteNetworkChannelFn func(context.Context, store.NetworkChannelEntry) error |
| 65 | PatchNetworkChannelFn func(context.Context, store.NetworkChannelRef, store.NetworkChannelPatch) error |
| 66 | DeleteNetworkChannelFn func(context.Context, store.NetworkChannelRef) error |
| 67 | WriteNetworkAuditFn func(context.Context, store.NetworkAuditEntry) error |
| 68 | ListNetworkAuditFn func(context.Context, store.NetworkAuditQuery) ([]store.NetworkAuditEntry, error) |
| 69 | WriteNetworkMessageFn func(context.Context, store.NetworkMessageEntry) error |
| 70 | ListNetworkMessagesFn func(context.Context, store.NetworkMessageQuery) ([]store.NetworkMessageEntry, error) |
| 71 | PutNetworkSubscriptionFn func(context.Context, store.NetworkSubscriptionEntry) error |
| 72 | ListNetworkSubscriptionsFn func( |
| 73 | context.Context, |
| 74 | store.NetworkSubscriptionQuery, |
| 75 | ) ([]store.NetworkSubscriptionEntry, error) |
| 76 | DeleteNetworkSubscriptionFn func(context.Context, store.NetworkSubscriptionRef) error |
| 77 | GetNetworkDeliveryGuidanceStateFn func(context.Context, string) (store.NetworkDeliveryGuidanceState, error) |
| 78 | PutNetworkDeliveryGuidanceStateFn func(context.Context, store.NetworkDeliveryGuidanceState) error |
| 79 | PutNetworkTaskThreadOriginFn func(context.Context, store.NetworkTaskThreadOrigin) error |
| 80 | ListNetworkTaskThreadOriginsFn func( |
| 81 | context.Context, |
nothing calls this directly
no outgoing calls
no test coverage detected