(ctx context.Context, events []*EventConfig, eventType db.EventType, dbcontext *db.DatabaseContext)
| 1628 | } |
| 1629 | |
| 1630 | func (sc *ServerContext) processEventHandlersForEvent(ctx context.Context, events []*EventConfig, eventType db.EventType, dbcontext *db.DatabaseContext) error { |
| 1631 | |
| 1632 | for _, event := range events { |
| 1633 | switch event.HandlerType { |
| 1634 | case "webhook": |
| 1635 | wh, err := db.NewWebhook(ctx, event.Url, event.Filter, event.Timeout, event.Options) |
| 1636 | if err != nil { |
| 1637 | base.WarnfCtx(ctx, "Error creating webhook %v", err) |
| 1638 | return err |
| 1639 | } |
| 1640 | dbcontext.EventMgr.RegisterEventHandler(ctx, wh, eventType) |
| 1641 | default: |
| 1642 | return errors.New(fmt.Sprintf("Unknown event handler type %s", event.HandlerType)) |
| 1643 | } |
| 1644 | |
| 1645 | } |
| 1646 | return nil |
| 1647 | } |
| 1648 | |
| 1649 | // RemoveDatabase is called when an external request is made to delete the database |
| 1650 | func (sc *ServerContext) RemoveDatabase(ctx context.Context, dbName string, reason string) bool { |
no test coverage detected