84 lines
3.4 KiB
Go
84 lines
3.4 KiB
Go
package main
|
|
|
|
import (
|
|
"context"
|
|
"net/http"
|
|
|
|
"git.cin.su/m/Assistant/adapters/notificationexecutor"
|
|
"git.cin.su/m/Assistant/contracts/capability"
|
|
commitcontract "git.cin.su/m/Assistant/contracts/commit"
|
|
"git.cin.su/m/Assistant/contracts/identity"
|
|
"git.cin.su/m/Assistant/modules/commit/ports"
|
|
)
|
|
|
|
type notificationBindingSource interface {
|
|
ActiveCapabilityBinding(context.Context, capability.CapabilityID, identity.PrincipalID) (capability.Binding, error)
|
|
CapabilityBinding(context.Context, capability.CapabilityBindingID, int64) (capability.Binding, error)
|
|
ResolveCandidateCapabilityBinding(context.Context, capability.CandidateReleaseContext) (capability.CandidateBindingResolution, error)
|
|
}
|
|
|
|
type operationDispatcher struct {
|
|
continuityExecutor ports.Executor
|
|
continuityReconciler ports.Reconciler
|
|
bindings notificationBindingSource
|
|
secretRef string
|
|
secret string
|
|
client *http.Client
|
|
candidateContext *capability.CandidateReleaseContext
|
|
}
|
|
|
|
func (d operationDispatcher) Execute(action commitcontract.AuthorizedAction) ports.ExecutionResult {
|
|
if action.Proposal.Operation != commitcontract.OperationDeliverProspectiveNotification {
|
|
return d.continuityExecutor.Execute(action)
|
|
}
|
|
subject := action.Proposal.NotificationSubject
|
|
if d.candidateContext != nil {
|
|
resolved, err := d.bindings.ResolveCandidateCapabilityBinding(context.Background(), *d.candidateContext)
|
|
if err != nil || resolved.Mode != capability.CandidateBindingModeShadow || resolved.Binding.Context != *d.candidateContext {
|
|
return ports.ExecutionResult{Known: true}
|
|
}
|
|
if subject.BindingID != resolved.Binding.BaseActiveBindingID || subject.BindingRevision != resolved.Binding.BaseActiveBindingRevision {
|
|
return ports.ExecutionResult{Known: true}
|
|
}
|
|
executor, err := notificationexecutor.NewShadow(resolved.Binding, d.secret, d.client)
|
|
if err != nil {
|
|
return ports.ExecutionResult{Known: true}
|
|
}
|
|
return executor.Execute(action)
|
|
}
|
|
exact, err := d.bindings.CapabilityBinding(context.Background(), subject.BindingID, subject.BindingRevision)
|
|
if err != nil || exact.SecretRef != d.secretRef {
|
|
return ports.ExecutionResult{Known: true}
|
|
}
|
|
active, err := d.bindings.ActiveCapabilityBinding(context.Background(), action.Proposal.CapabilityID, action.PrincipalID)
|
|
if err != nil || active != exact {
|
|
return ports.ExecutionResult{Known: true}
|
|
}
|
|
executor, err := notificationexecutor.New(exact, d.secret, d.client)
|
|
if err != nil {
|
|
return ports.ExecutionResult{Known: true}
|
|
}
|
|
return executor.Execute(action)
|
|
}
|
|
|
|
func (d operationDispatcher) Reconcile(action commitcontract.AuthorizedAction) ports.ExecutionResult {
|
|
if action.Proposal.Operation != commitcontract.OperationDeliverProspectiveNotification {
|
|
return d.continuityReconciler.Reconcile(action)
|
|
}
|
|
if d.candidateContext != nil {
|
|
// A candidate shadow delivery is never reconciled against the ACTIVE
|
|
// production target. Its typed receipt is the sole candidate evidence.
|
|
return ports.ExecutionResult{Known: true}
|
|
}
|
|
subject := action.Proposal.NotificationSubject
|
|
exact, err := d.bindings.CapabilityBinding(context.Background(), subject.BindingID, subject.BindingRevision)
|
|
if err != nil || exact.SecretRef != d.secretRef {
|
|
return ports.ExecutionResult{}
|
|
}
|
|
reconciler, err := notificationexecutor.NewReconciler(exact, d.secret, d.client)
|
|
if err != nil {
|
|
return ports.ExecutionResult{}
|
|
}
|
|
return reconciler.Reconcile(action)
|
|
}
|