yehohanan7 / flux Goto Github PK

package main

import (
	"fmt"

	"github.com/satori/go.uuid"
	"github.com/yehohanan7/flux"
	"github.com/yehohanan7/flux/cqrs"
)

//Object

type InventoryItem struct {
	cqrs.Aggregate
	Activated bool
}

func (ii *InventoryItem) Deactivate() error {
	if !ii.Activated {
		return fmt.Errorf("InventoryItem already deactivated")
	}
	ii.Update(InventoryItemDeactivated{}) //-> Trigger the Handle deactivated...
	//---> Activated is True
	return nil
}

//Events

type InventoryItemCreated struct {
	Id string
}

type InventoryItemDeactivated struct {
}

//Event handlers

func (ii *InventoryItem) HandleInventoryItemCreated(event InventoryItemCreated) {
	ii.Id = event.Id
	ii.Activated = true
}

func (ii *InventoryItem) HandleInventoryItemDeactivated(event InventoryItemDeactivated) {
	ii.Activated = false
	// --> Event is handled while doing the update and Activated properly set to False
}

func NewInventoryItem(id uuid.UUID) InventoryItem {
	inventoryItem := new(InventoryItem)
	var aggregateId = id.String()
	inventoryItem.Aggregate = cqrs.NewAggregate(aggregateId, inventoryItem, store)
	inventoryItem.Update(InventoryItemCreated{aggregateId})
	return *inventoryItem
}

var store = flux.NewMemoryStore()

func main() {
	inventoryItem := NewInventoryItem(uuid.NewV4())
	// Activated is true...
	inventoryItem.Deactivate()
	//Activated is true...
	inventoryItem.Save()
	// Activated is True...
	fmt.Println(inventoryItem.Activated)

}