ui_receipt.go RawHistoryFolder

1package daemon
2
3import (
4	"errors"
5
6	"github.com/bnema/vev/internal/protocol"
7)
8
9func (d *Daemon) registerAttachmentUIFence(effect *attachmentEffect, actionID uint64) bool {
10	if !effect.current() {
11		return false
12	}
13	capability := effect.capability()
14	rc := attachmentRenderCoordinator(capability.sess)
15	return rc != nil && rc.registerUIFence(capability.lease, actionID, func(id uint64) {
16		d.expireAttachmentUIFence(capability, id)
17	})
18}
19
20func (d *Daemon) expireAttachmentUIFence(capability attachmentCapability, actionID uint64) {
21	effect, ok := capability.ac.beginAttachmentEffect(capability)
22	if !ok {
23		return
24	}
25	defer effect.End()
26	// Unavailability confirms no publication. In particular, do not synthesize
27	// a successful boundary from mutable output state when rendering timed out.
28	if err := effect.sendControl(protocol.UIReceipt{ActionID: actionID, Outcome: protocol.UIReceiptUnavailable}); err != nil {
29		launchCleanup := d.reserveAttachmentSendErrorCleanup(capability, capability.transport.transport)
30		effect.End()
31		launchCleanup()
32	}
33}
34
35// sendUIReceiptLocked shares the attachment's Output/UIViewUpdate send ordering.
36// Callers hold sendMu, never coordinator.mu. A nil effect is the existing direct
37// render fixture path, not a separate production transport owner.
38func sendUIReceiptLocked(effect *attachmentEffect, transport transportSnapshot, receipt protocol.UIReceipt) error {
39	if transport.transport == nil {
40		return errors.New("client transport is nil")
41	}
42	if effect != nil {
43		if !effect.current() || !effect.beginTransportSend(transport) {
44			return errAttachmentTransition
45		}
46		defer effect.endTransportSend()
47	}
48	var err error
49	if transport.transport.Capabilities().AsyncSend {
50		err = transport.transport.SendServerAsync(receipt)
51	} else {
52		err = transport.transport.SendServer(receipt)
53	}
54	if err != nil && effect != nil {
55		effect.reportTransportFailure(transport)
56	}
57	return err
58}