MCPcopy Create free account
hub / github.com/daodst/chat / SelectMaxStreamIDForUser

Method SelectMaxStreamIDForUser

keyserver/storage/tables/interface.go:40–40  ·  view source on GitHub ↗
(ctx context.Context, txn *sql.Tx, userID string)

Source from the content-addressed store, hash-verified

38 SelectDeviceKeysJSON(ctx context.Context, keys []api.DeviceMessage) error
39 InsertDeviceKeys(ctx context.Context, txn *sql.Tx, keys []api.DeviceMessage) error
40 SelectMaxStreamIDForUser(ctx context.Context, txn *sql.Tx, userID string) (streamID int64, err error)
41 CountStreamIDsForUser(ctx context.Context, userID string, streamIDs []int64) (int, error)
42 SelectBatchDeviceKeys(ctx context.Context, userID string, deviceIDs []string, includeEmpty bool) ([]api.DeviceMessage, error)
43 DeleteDeviceKeys(ctx context.Context, txn *sql.Tx, userID, deviceID string) error

Callers 1

StoreLocalDeviceKeysMethod · 0.65

Implementers 2

deviceKeysStatementskeyserver/storage/postgres/device_keys
deviceKeysStatementskeyserver/storage/sqlite3/device_keys_

Calls

no outgoing calls

Tested by

no test coverage detected