Go SDK

client := twinmemory.New(os.Getenv("TWIN_MEMORY_API_KEY"))

_, err := client.Add(ctx, "user_42", []twinmemory.Item{{ID: "msg-001", Session: "onboarding", Role: "user", Text: "I just moved to Lisbon."}})
brief, err := client.Search(ctx, "user_42", "Where does Alice live?")
receipt, err := client.Forget(ctx, "user_42", twinmemory.Forget{Items: []string{"msg-001"}})

package twin

import (
	"bytes"
	"context"
	"encoding/json"
	"fmt"
	"io"
	"net/http"
	"os"
)

const base = "https://api.twinmemory.dev/v1/memory/"

// Call posts body to one route for one end user and decodes the answer into out.
// It reports found=false on a 404: nothing was ever written for this end user.
func Call(ctx context.Context, user, route string, body, out any) (found bool, err error) {
	payload, err := json.Marshal(body)
	if err != nil {
		return false, err
	}
	req, err := http.NewRequestWithContext(ctx, http.MethodPost, base+route, bytes.NewReader(payload))
	if err != nil {
		return false, err
	}
	req.Header.Set("Authorization", "Bearer "+os.Getenv("TWIN_MEMORY_API_KEY"))
	req.Header.Set("X-Twin-Account", user)
	req.Header.Set("Content-Type", "application/json")
	res, err := http.DefaultClient.Do(req)
	if err != nil {
		return false, err
	}
	defer res.Body.Close()
	if res.StatusCode == http.StatusNotFound && route != "correct" {
		return false, nil
	}
	if res.StatusCode >= 300 {
		detail, _ := io.ReadAll(res.Body)
		return false, fmt.Errorf("%s: %d %s", route, res.StatusCode, detail)
	}
	return true, json.NewDecoder(res.Body).Decode(out)
}

type Item map[string]any

var added map[string]any
_, err := twin.Call(ctx, "user_42", "add", map[string]any{"items": []Item{{
	"id": "msg-001", "session": "onboarding", "role": "user",
	"text": "I just moved to Lisbon from Berlin for the new job at Acme.",
}}}, &added)

var brief struct {
	Known []string `json:"known"`
	Facts []struct{ ID, Text, Source string } `json:"facts"`
	Hits  []struct{ ID, Path, Text string }   `json:"hits"`
	Held  *bool                               `json:"held"`
}
found, err := twin.Call(ctx, "user_42", "search", map[string]any{"query": "Where does Alice live?"}, &brief)

var receipt map[string]any
_, err = twin.Call(ctx, "user_42", "forget", map[string]any{"items": []string{"msg-001"}}, &receipt)