mirror of
https://github.com/usememos/memos.git
synced 2025-10-31 00:38:08 +08:00
50 lines
1.1 KiB
Go
50 lines
1.1 KiB
Go
package store
|
|
|
|
import (
|
|
"context"
|
|
|
|
storepb "github.com/usememos/memos/proto/gen/store"
|
|
)
|
|
|
|
type FindWebhook struct {
|
|
ID *int32
|
|
CreatorID *int32
|
|
}
|
|
|
|
type UpdateWebhook struct {
|
|
ID int32
|
|
RowStatus *storepb.RowStatus
|
|
Name *string
|
|
URL *string
|
|
}
|
|
|
|
type DeleteWebhook struct {
|
|
ID int32
|
|
}
|
|
|
|
func (s *Store) CreateWebhook(ctx context.Context, create *storepb.Webhook) (*storepb.Webhook, error) {
|
|
return s.driver.CreateWebhook(ctx, create)
|
|
}
|
|
|
|
func (s *Store) ListWebhooks(ctx context.Context, find *FindWebhook) ([]*storepb.Webhook, error) {
|
|
return s.driver.ListWebhooks(ctx, find)
|
|
}
|
|
|
|
func (s *Store) GetWebhooks(ctx context.Context, find *FindWebhook) (*storepb.Webhook, error) {
|
|
list, err := s.ListWebhooks(ctx, find)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
if len(list) == 0 {
|
|
return nil, nil
|
|
}
|
|
return list[0], nil
|
|
}
|
|
|
|
func (s *Store) UpdateWebhook(ctx context.Context, update *UpdateWebhook) (*storepb.Webhook, error) {
|
|
return s.driver.UpdateWebhook(ctx, update)
|
|
}
|
|
|
|
func (s *Store) DeleteWebhook(ctx context.Context, delete *DeleteWebhook) error {
|
|
return s.driver.DeleteWebhook(ctx, delete)
|
|
}
|