tink server state machine

state.txt

server
┌────────────────────────────────────────────────────────────────────────────────────────────────────┐
│                                   next                                                             │
│               ┌────────────────────────────────────────────────┐                                   │
│               │                                                │                                   │
│               ▼                                                │                                   │
│         ┌───────────┐             ┌──────────┐           ┌─────┴─────┐          ┌──────────┐       │
│         │           │             │          │ success   │           │  end     │          │       │
────────► │ pending   ├───────────► │ running  ├─┬───────► │ success   ├─────────►│ complete │       │
│         │           │  received   │          │ │         │           │          │          │       │
│         │           │             │          │ │         └─────┬─────┘          └──────────┘       │
│         └───┬───────┘             └──────────┘ │               │                                   │
│             │                                  │               │failed-builtin                     │
│             │                                  │               ▼                                   │
│             │                                  │         ┌───────────┐                             │
│             │                                  │         │           │                             │
│             │                                  └───────► │ failed    │                             │
│             │                                  failure   │           │                             │
│             │                                            └───────────┘                             │
│             │                                                                                      │
│             │                                                                                      │
│             │                                                                                      │
│             │                                                                                      │
│             │                                                                                      │
│             │        ┌─────────────────┐                                                           │
│             │        │  state machine  │                                                           │
│             │        │  event handler  │                                                           │
│             │        │                 │                                                           │
│             │        │                 │                                                           │
│             │        └─────────────────┘                                                           │
│             │            ▲                                                                         │
│             │            │                                                                         │
│             │            │                                                                         │
│             ▼            │                                                                         │
│         ┌────────────────┴─────────┐                                                               │
│         │ Workflow Execution       │                                                               │
└─────────┴──────────────────────────┴───────────────────────────────────────────────────────────────┘
                  ▲
                  │event
                  │
                gRPC Bidirectional Stream
                  │
                  │action
                  ▼                               client
┌─────────┬──────────────────────────┬───────────────────────────────────────────────────────────────┐
│         │                          │                                                               │
│         └──────────────────────────┘                                                               │
│                                                                                                    │
│              for {                                                                                 │
│              		action, err := stream.Recv()                                                       |  
│              		if err != nil {                                                                    |  
│              			continue                                                                         |   
│              		}                                                                                  |  
│              		if err := stream.Send("received"); err != nil {                                    |  
│              			// log error                                                                     |   
│              			continue                                                                         |   
│              		}                                                                                  |  
│              		// handle built-in actions                                                                |  
│              		var builtin bool                                                                   |  
│              		if action == "reboot" || action == "kexec" {                                       |  
│              			builtin = true                                                                   |   
│              			if err := stream.Send("success"); err != nil {                                   |   
│              				// log error                                                                   |    
│              				continue                                                                       |    
│              			}                                                                                |   
│              		}                                                                                  |  
│              		result, err := execute(action)                                                     |  
│              		if err != nil {                                                                    |  
│              			// log error                                                                     |   
│              			result = "failure"                                                               |   
│              			if builtin {                                                                     |   
│              				result = "failed-builtin"                                                      |    
│              			}                                                                                |   
│              		}                                                                                  |  
│              		if err := stream.Send(result); err != nil {                                        |  
│              			// log error                                                                     |   
│              			continue                                                                         |   
│              		}                                                                                  |  
│              	}                                                                                    | 
└────────────────────────────────────────────────────────────────────────────────────────────────────┘