BoolAndOp

package main

import (
	"context"
	"encoding/json"
	"log"
	"os"
	"time"

	"github.com/akennis/sparsi-go/library"
	_ "github.com/akennis/dagor/operator/builtin"

	"github.com/panjf2000/ants/v2"
	"github.com/akennis/dagor"
	"github.com/akennis/dagor/graph"
)

func main() {
	isValidEmail := true
	isSubscribed := false

	library.RegisterConst("valid_email_val", isValidEmail)
	library.RegisterConst("subscribed_val", isSubscribed)

	g, err := graph.NewBuilder("bool_and_demo").
		Vertex("email_src").Op("valid_email_val").
		Output("Result", "valid_email_wire").

		Vertex("sub_src").Op("subscribed_val").
		Output("Result", "subscribed_wire").

		Vertex("and_gate").Op("BoolAndOp").
		Input("A", "valid_email_wire").
		Input("B", "subscribed_wire").
		Output("Result", "can_send_email").

		Build()
	if err != nil {
		log.Fatalf("build: %v", err)
	}

	pool, err := ants.NewPool(4)
	if err != nil {
		log.Fatalf("pool: %v", err)
	}
	defer pool.Release()

	eng, err := dagor.NewEngine(g, pool)
	if err != nil {
		log.Fatalf("engine: %v", err)
	}

	ctx, cancel := context.WithTimeout(context.Background(), 2*time.Minute)
	defer cancel()

	if err := eng.Run(ctx); err != nil {
		log.Fatalf("run: %v", err)
	}

	out := map[string]any{
		"is_valid_email": isValidEmail,
		"is_subscribed":  isSubscribed,
	}
	if raw, ok := eng.GetOutput("can_send_email"); ok {
		out["can_send_email"] = *raw.(*bool)
	}

	enc := json.NewEncoder(os.Stdout)
	enc.SetIndent("", "  ")
	enc.Encode(out)
}