- Kind
- Pure package
- Name
- memba_weighted_host
- Namespace
- samcrew
- Exported functions
- n/a — not supported for pure packages by the node (vm/qfuncs)
- Module
- gno.land/p/samcrew/memba_weighted_host
- gno
- 0.9
gno
feedback_host.gnogno
1package memba_weighted_host23import (4 "chain"5 "gno.land/p/samcrew/memba_weighted_policy"6)78
not supported for pure packages by the node (vm/qfuncs)
Signatures reconstructed verbatim from vm/qfuncs — interface params keep their inline definitions.
type FeedbackState struct {
9 Owner, PendingOwner address
10 Paused bool
11 MemberCount int
12 MembershipRevision uint64
13 OwnerMember, DAOMember, SuccessorMember, SubjectMember bool
14 OwnerRoles, DAORoles, SuccessorRoles, SubjectRoles string
15 ChannelCount int
16 ChannelExists bool
17 ChannelDescription, ChannelType, ChannelReadRoles, ChannelWriteRoles string
18}
19type feedbackProposal struct { action FeedbackAction; before FeedbackState }
20
21func feedbackCommitment(a FeedbackAction, s FeedbackState) string {
22 return a.Bytes()+"|before|"+feedbackStateJSON(s)
23}
24func (h *Host) validateFeedback(a FeedbackAction, s FeedbackState) {
25 if h.feedbackPolicy==nil { panic("feedback actions are not configured") }
26 a.Bytes()
27 p:=h.feedbackPolicy
28 if !s.Owner.IsValid() || (s.PendingOwner!="" && !s.PendingOwner.IsValid()) || s.MemberCount<1 || !s.OwnerMember || s.ChannelCount<0 || s.ChannelCount>20 {
29 panic("invalid feedback authority pre-state")
30 }
31 if a.Subject()=="" && (s.SubjectMember || s.SubjectRoles!="") { panic("unexpected feedback subject pre-state") }
32 if a.Name()=="" && (s.ChannelExists || s.ChannelDescription!="" || s.ChannelType!="" || s.ChannelReadRoles!="" || s.ChannelWriteRoles!="") { panic("unexpected feedback creation pre-state") }
33 if a.Kind()==FeedbackAcceptOwner {
34 if s.Owner!=p.Successor() || s.PendingOwner!=p.DAO() || s.DAOMember || !s.SuccessorMember || s.OwnerRoles!="admin" || s.SuccessorRoles!="admin" {
35 panic("publisher is not pending feedback handoff or DAO already has membership")
36 }
37 return
38 }
39 if s.Owner!=p.DAO() || !s.DAOMember || s.DAORoles!=s.OwnerRoles { panic("DAO is not feedback owner") }
40 if a.Kind()==FeedbackAbortReturn {
41 if a.Recipient()!=p.Successor() || s.PendingOwner!=p.Successor() { panic("feedback return does not match policy") }
42 return
43 }
44 if s.PendingOwner!="" { panic("feedback authority transfer is pending") }
45 switch a.Kind() {
46 case FeedbackReturnOwner:
47 if a.Recipient()!=p.Successor() || s.SuccessorMember { panic("feedback successor mismatch or preexisting membership") }
48 case FeedbackAddMember, FeedbackRemoveMember, FeedbackSetRoles:
49 if a.Subject()==p.DAO() || a.Subject()==chain.PackageAddress(FeedbackPath) || (a.Subject()==p.Successor() && a.Kind()!=FeedbackRemoveMember) {
50 panic("feedback member action targets protected authority")
51 }
52 if a.Kind()==FeedbackAddMember && s.SubjectMember { panic("feedback member already exists") }
53 if a.Kind()!=FeedbackAddMember && !s.SubjectMember { panic("feedback member does not exist") }
54 if a.Kind()==FeedbackSetRoles && s.SubjectRoles==a.Roles() { panic("feedback roles are unchanged") }
55 case FeedbackCreateText:
56 if s.ChannelCount>=20 || s.ChannelExists { panic("feedback text creation unavailable") }
57 case FeedbackUnpause:
58 if !s.Paused { panic("feedback unpause is a no-op") }
59 default: panic("unsupported feedback action")
60 }
61}
62func (h *Host) ProposeFeedback(a FeedbackAction, s FeedbackState, rlm realm) uint64 {
63 who:=assertCaller(h,rlm)
64 h.validateFeedback(a,s)
65 p:=&roleProposal{proposer:who,feedback:&feedbackProposal{action:a,before:s}}
66 p.ballot=h.policy.NewProposal(a.Category(),feedbackCommitment(a,s))
67 h.addProposal(p)
68 return uint64(len(h.proposals))
69}
70func (h *Host) invalidateFeedbackPeers(cause string, id uint64) {
71 members:=[]memba_weighted_policy.Member{}
72 for _,seat:=range h.seats { members=append(members,seat.Member) }
73 h.policy.Reconfigure(members)
74 h.recordInvalidation(cause, id, FeedbackPath)
75}
76func (h *Host) ConsumeFeedback(id uint64, s FeedbackState, rlm realm) FeedbackAction {
77 assertCaller(h,rlm)
78 p:=h.proposal(id)
79 if p.feedback==nil { panic("proposal is not a feedback action") }
80 h.validateFeedback(p.feedback.action,s)
81 p.ballot.Consume(feedbackCommitment(p.feedback.action,s))
82 h.invalidateFeedbackPeers(InvalidatedByExecution, id)
83 return p.feedback.action
84}
85func (h *Host) PrepareFeedbackEmergencyPause(s FeedbackState, rlm realm) {
86 assertCaller(h,rlm)
87 if h.feedbackPolicy==nil || s.Owner!=h.feedbackPolicy.DAO() || s.Paused || !s.OwnerMember || !s.DAOMember || s.DAORoles!=s.OwnerRoles {
88 panic("feedback emergency pause unavailable")
89 }
90 h.invalidateFeedbackPeers(InvalidatedByPause, 0)
91}
92