subscriptions

type Condition struct {
	Not bool `protobuf:"varint,1,opt,name=not,proto3" json:"not,omitempty"`
	// Types that are assignable to Cond:
	//
	//	*Condition_Gc
	//	*Condition_Tc
	//	*Condition_Nc
	Cond isCondition_Cond `protobuf_oneof:"cond"`
	// contains filtered or unexported fields
}

type Condition_Gc struct {
	Gc *GroupCondition `protobuf:"bytes,2,opt,name=gc,proto3,oneof"`
}

type Condition_Nc struct {
	Nc *NumberCondition `protobuf:"bytes,4,opt,name=nc,proto3,oneof"`
}

type Condition_Tc struct {
	Tc *TextCondition `protobuf:"bytes,3,opt,name=tc,proto3,oneof"`
}

type CreateRequest struct {
	Description string                 `protobuf:"bytes,1,opt,name=description,proto3" json:"description,omitempty"`
	Enabled     bool                   `protobuf:"varint,2,opt,name=enabled,proto3" json:"enabled,omitempty"`
	Cond        *Condition             `protobuf:"bytes,3,opt,name=cond,proto3" json:"cond,omitempty"`
	Expires     *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=expires,proto3" json:"expires,omitempty"`
	Public      bool                   `protobuf:"varint,5,opt,name=public,proto3" json:"public,omitempty"`
	// contains filtered or unexported fields
}

type CreateResponse struct {
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

type Cursor struct {
	Id        string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Followers int64  `protobuf:"varint,2,opt,name=followers,proto3" json:"followers,omitempty"`
	// contains filtered or unexported fields
}

type DeleteRequest struct {
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

type DeleteResponse struct {
	// contains filtered or unexported fields
}

type GroupCondition struct {
	Logic GroupLogic   `protobuf:"varint,1,opt,name=logic,proto3,enum=awakari.interests.api.GroupLogic" json:"logic,omitempty"`
	Group []*Condition `protobuf:"bytes,2,rep,name=group,proto3" json:"group,omitempty"`
	// contains filtered or unexported fields
}

type GroupLogic int32

type NumberCondition struct {
	Id  string    `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` // skip when create
	Key string    `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"`
	Op  Operation `protobuf:"varint,3,opt,name=op,proto3,enum=awakari.interests.api.Operation" json:"op,omitempty"`
	Val float64   `protobuf:"fixed64,4,opt,name=val,proto3" json:"val,omitempty"`
	// contains filtered or unexported fields
}

type Operation int32

type Order int32

type ReadRequest struct {
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

type ReadResponse struct {
	Description string                 `protobuf:"bytes,1,opt,name=description,proto3" json:"description,omitempty"`
	Enabled     bool                   `protobuf:"varint,2,opt,name=enabled,proto3" json:"enabled,omitempty"`
	Cond        *Condition             `protobuf:"bytes,3,opt,name=cond,proto3" json:"cond,omitempty"`
	Expires     *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=expires,proto3" json:"expires,omitempty"`
	Created     *timestamppb.Timestamp `protobuf:"bytes,5,opt,name=created,proto3" json:"created,omitempty"`
	Updated     *timestamppb.Timestamp `protobuf:"bytes,6,opt,name=updated,proto3" json:"updated,omitempty"`
	Public      bool                   `protobuf:"varint,7,opt,name=public,proto3" json:"public,omitempty"`
	Followers   int64                  `protobuf:"varint,8,opt,name=followers,proto3" json:"followers,omitempty"`
	// contains filtered or unexported fields
}

type SearchOwnRequest struct {
	Cursor  string `protobuf:"bytes,1,opt,name=cursor,proto3" json:"cursor,omitempty"`
	Limit   uint32 `protobuf:"varint,2,opt,name=limit,proto3" json:"limit,omitempty"`
	Order   Order  `protobuf:"varint,3,opt,name=order,proto3,enum=awakari.interests.api.Order" json:"order,omitempty"`
	Pattern string `protobuf:"bytes,4,opt,name=pattern,proto3" json:"pattern,omitempty"`
	// contains filtered or unexported fields
}

type SearchOwnResponse struct {
	Ids []string `protobuf:"bytes,1,rep,name=ids,proto3" json:"ids,omitempty"`
	// contains filtered or unexported fields
}

type SearchRequest struct {
	Cursor  *Cursor `protobuf:"bytes,1,opt,name=cursor,proto3" json:"cursor,omitempty"`
	Limit   uint32  `protobuf:"varint,2,opt,name=limit,proto3" json:"limit,omitempty"`
	Order   Order   `protobuf:"varint,3,opt,name=order,proto3,enum=awakari.interests.api.Order" json:"order,omitempty"`
	Pattern string  `protobuf:"bytes,4,opt,name=Pattern,proto3" json:"Pattern,omitempty"`
	Sort    Sort    `protobuf:"varint,5,opt,name=sort,proto3,enum=awakari.interests.api.Sort" json:"sort,omitempty"`
	// contains filtered or unexported fields
}

type SearchResponse struct {
	Ids []string `protobuf:"bytes,1,rep,name=ids,proto3" json:"ids,omitempty"`
	// contains filtered or unexported fields
}

type Service interface {

	// Create a subscription with the specified fields.
	Create(ctx context.Context, userId string, subData subscription.Data) (id string, err error)

	// Read returns the subscription specified by the id. Returns ErrNotFound if subscription is missing.
	Read(ctx context.Context, userId, subId string) (subData subscription.Data, err error)

	// Update the subscription.Data
	Update(ctx context.Context, userId, subId string, subData subscription.Data) (err error)

	// Delete the specified subscription all associated conditions those not in use by any other subscription.
	// Returns ErrNotFound if a subscription with the specified id is missing.
	Delete(ctx context.Context, userId, subId string) (err error)

	// Search returns all subscription ids matching the query.
	Search(ctx context.Context, userId string, q subscription.Query, cursor subscription.Cursor) (ids []string, err error)
}

type ServiceClient interface {
	Create(ctx context.Context, in *CreateRequest, opts ...grpc.CallOption) (*CreateResponse, error)
	Read(ctx context.Context, in *ReadRequest, opts ...grpc.CallOption) (*ReadResponse, error)
	Update(ctx context.Context, in *UpdateRequest, opts ...grpc.CallOption) (*UpdateResponse, error)
	Delete(ctx context.Context, in *DeleteRequest, opts ...grpc.CallOption) (*DeleteResponse, error)
	SearchOwn(ctx context.Context, in *SearchOwnRequest, opts ...grpc.CallOption) (*SearchOwnResponse, error)
	Search(ctx context.Context, in *SearchRequest, opts ...grpc.CallOption) (*SearchResponse, error)
}

type ServiceServer interface {
	Create(context.Context, *CreateRequest) (*CreateResponse, error)
	Read(context.Context, *ReadRequest) (*ReadResponse, error)
	Update(context.Context, *UpdateRequest) (*UpdateResponse, error)
	Delete(context.Context, *DeleteRequest) (*DeleteResponse, error)
	SearchOwn(context.Context, *SearchOwnRequest) (*SearchOwnResponse, error)
	Search(context.Context, *SearchRequest) (*SearchResponse, error)
}

type Sort int32

type TextCondition struct {
	Id    string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` // leave it unset when create
	Key   string `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"`
	Term  string `protobuf:"bytes,3,opt,name=term,proto3" json:"term,omitempty"`
	Exact bool   `protobuf:"varint,4,opt,name=exact,proto3" json:"exact,omitempty"`
	// contains filtered or unexported fields
}

type UnimplementedServiceServer struct {
}

type UpdateRequest struct {
	Id          string                 `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Description string                 `protobuf:"bytes,2,opt,name=description,proto3" json:"description,omitempty"`
	Enabled     bool                   `protobuf:"varint,3,opt,name=enabled,proto3" json:"enabled,omitempty"`
	Expires     *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=expires,proto3" json:"expires,omitempty"`
	Cond        *Condition             `protobuf:"bytes,5,opt,name=cond,proto3" json:"cond,omitempty"`
	Public      bool                   `protobuf:"varint,6,opt,name=public,proto3" json:"public,omitempty"`
	// contains filtered or unexported fields
}

type UpdateResponse struct {
	// contains filtered or unexported fields
}