code.oscarkilo.com/okg #25b69d4f290e41e73b0d35ae04e8e9697f85ef6e

Hash:

25b69d4f290e41e73b0d35ae04e8e9697f85ef6e

Author:

Date:

Thu Jun 4 20:50:27 2026 -0400

Message:

okg: add `okg group add-member` (variadic users) POST /groups/join via //okg/who's new JoinGroups method. CLI shape: `okg group add-member GROUP USER [USER ...]`. Server-side /groups/join is N-by-M (pairs every listed group with every listed member), but the CLI commits to one group at a time so the agent UX stays unambiguous. Multiple members in a single call still work — handy when seeding a fresh chat channel with a known bot roster. Test: TestJoinGroups pins the POST path + JSON shape.

diff --git a/README.md b/README.md
index 259e4ed..59d442f 100644
--- a/README.md
+++ b/README.md
@@ -56,8 +56,9 @@ okg pr reopen NUMBER

okg auth login [--key KEY] [--host HOST]

-okg group list [--json]
-okg group create NAME [--full-name TEXT] [--owner USER]
+okg group list [--json]
+okg group create NAME [--full-name TEXT] [--owner USER]
+okg group add-member GROUP USER [USER ...]

okg embed [--model NAME] [--dims N] [--full-path]
(reads stdin → vectors on stdout)
diff --git a/group.go b/group.go
index 1aa487c..beab408 100644
--- a/group.go
+++ b/group.go
@@ -19,6 +19,8 @@ func runGroup(args []string) error {
return runGroupList(args[1:])
case "create":
return runGroupCreate(args[1:])
+ case "add-member":
+ return runGroupAddMember(args[1:])
default:
return fmt.Errorf(
"unknown group subcommand: %s", args[0])
@@ -106,6 +108,35 @@ func runGroupCreate(args []string) error {
return nil
}

+func runGroupAddMember(args []string) error {
+ fs := flag.NewFlagSet(
+ "group add-member", flag.ContinueOnError)
+ if err := fs.Parse(args); err != nil {
+ return err
+ }
+ positional := fs.Args()
+ if len(positional) < 2 {
+ return fmt.Errorf(
+ "usage: okg group add-member GROUP USER [USER ...]")
+ }
+ group := positional[0]
+ members := positional[1:]
+
+ c, err := newWhoClient()
+ if err != nil {
+ return err
+ }
+ if err := c.JoinGroups(who.JoinGroupsRequest{
+ GroupUsernames: []string{group},
+ MemberUsernames: members,
+ }); err != nil {
+ return err
+ }
+ fmt.Printf(
+ "Added %d member(s) to %s\n", len(members), group)
+ return nil
+}
+
// newWhoClient builds a //who client from saved config. Shared
// by every `okg group` subcommand.
func newWhoClient() (*who.HTTPClient, error) {
diff --git a/main.go b/main.go
index 33ef96a..23cd231 100644
--- a/main.go
+++ b/main.go
@@ -63,6 +63,8 @@ GROUPS
--full-name TEXT display name (default: NAME)
--owner USER owner username (default: caller)

+ okg group add-member GROUP USER [USER ...]
+
PULL REQUESTS
okg pr list
--state STATE open or closed (default: open)
@@ -128,6 +130,7 @@ EXAMPLES
Groups
okg group list
okg group create chat-bots
+ okg group add-member chat-bots claude openclaw

Pull requests
okg pr list --state open
diff --git a/who/who.go b/who/who.go
index 3a6aebf..aa2e82b 100644
--- a/who/who.go
+++ b/who/who.go
@@ -91,3 +91,16 @@ type CreateGroupRequest struct {
func (c *HTTPClient) CreateGroup(req CreateGroupRequest) error {
return c.PostJSON("/groups/add", req, nil)
}
+
+// JoinGroupsRequest is the body for POST /groups/join. The
+// server adds every (GroupUsernames[i], MemberUsernames[j])
+// pair, requiring the caller to be an owner of each group.
+type JoinGroupsRequest struct {
+ GroupUsernames []string `json:"group_usernames"`
+ MemberUsernames []string `json:"member_usernames"`
+}
+
+// JoinGroups adds members to groups (all pairwise combinations).
+func (c *HTTPClient) JoinGroups(req JoinGroupsRequest) error {
+ return c.PostJSON("/groups/join", req, nil)
+}
diff --git a/who/who_test.go b/who/who_test.go
index 639ce59..d0d4da1 100644
--- a/who/who_test.go
+++ b/who/who_test.go
@@ -141,3 +141,41 @@ func TestCreateGroup(t *testing.T) {
seen.OwnerUsername)
}
}
+
+func TestJoinGroups(t *testing.T) {
+ var seen JoinGroupsRequest
+ srv := httptest.NewServer(http.HandlerFunc(
+ func(w http.ResponseWriter, r *http.Request) {
+ if r.URL.Path != "/groups/join" {
+ t.Errorf(
+ "path: got %q, want /groups/join",
+ r.URL.Path)
+ }
+ if r.Method != "POST" {
+ t.Errorf("method: got %q, want POST", r.Method)
+ }
+ json.NewDecoder(r.Body).Decode(&seen)
+ w.WriteHeader(200)
+ }))
+ defer srv.Close()
+
+ c := NewHTTPClient(srv.URL, "test-key")
+ err := c.JoinGroups(JoinGroupsRequest{
+ GroupUsernames: []string{"team"},
+ MemberUsernames: []string{"alice", "bob"},
+ })
+ if err != nil {
+ t.Fatal(err)
+ }
+ if len(seen.GroupUsernames) != 1 ||
+ seen.GroupUsernames[0] != "team" {
+ t.Errorf(
+ "GroupUsernames: got %v, want [team]",
+ seen.GroupUsernames)
+ }
+ if len(seen.MemberUsernames) != 2 {
+ t.Errorf(
+ "MemberUsernames: got %v, want 2 members",
+ seen.MemberUsernames)
+ }
+}

# okg — Oscar Kilo Goodness

A command-line tool that bundles Oscar Kilo's externally usable

services into one binary. Today: git ops against

[klee](https://code.oscarkilo.com), and LLM embeddings against

[klex](https://oscarkilo.com/klex). More LLM utilities (`one`,

`exemplary`) coming as the legacy `klex-git` binaries fold in.

Designed for both humans and AI agents (Claude, OpenClaw) to

use directly from the command line.

## Install

```bash

go install oscarkilo.com/okg@latest

```

Or build from source:

```bash

git clone https://code.oscarkilo.com/okg

cd okg && go build .

```

## Setup

By default okg talks to the production klee host

(`https://code.oscarkilo.com`); the only setup you need is your

API key. `okg auth login` saves it to

`~/.config/okg/config.json`.

```bash

# Non-interactive (for agents and scripts).

okg auth login --key sk-...

cat ~/.klex.key | okg auth login # equivalent, ps-safe

# Interactive (prompts for host then key).

okg auth login

```

Override the host for dev/local work with `--host` on `auth login`.

## Commands

```

okg repo list

okg pr list [--state open|closed]

okg pr create --head BRANCH [--base master] --title TITLE [--body BODY]

okg pr view NUMBER

okg pr diff NUMBER

okg pr comment NUMBER --body BODY [--approve | --request-changes]

okg pr merge NUMBER

okg pr close NUMBER

okg pr reopen NUMBER

okg auth login [--key KEY] [--host HOST]

okg group list [--json]

okg group create NAME [--full-name TEXT] [--owner USER]

okg group add-member GROUP USER [USER ...]

okg embed [--model NAME] [--dims N] [--full-path]

(reads stdin → vectors on stdout)

okg one [--model NAME] [--system-file FILE] \

[--prompt-file FILE] [--attach FILE] \

[--format text|json|jsonindent] [--fast-fail]

(reads stdin as a JSON MessagesRequest)

```

### Coming next

- `okg exemplary` — few-shot batch runner (from

`klex-git/exemplary`).

Once that lands, the standalone `klex-git` binaries are

deprecated.

### Flags

- `--repo REPO` overrides auto-detected repo name

(normally parsed from `git remote get-url origin`)

- `--json` outputs raw JSON for any command

- `OKG_REPO` env var also overrides repo detection

## Repo Detection

Like `gh`, okg detects the repo from the current directory's

git remote:

```

git remote get-url origin

→ https://code.oscarkilo.com/widget.git

→ repo = "widget"

```

## Dependencies

- `oscarkilo.com/klex-git` for the LLM API client (transitional;

to be folded in once all `klex-git` binaries have moved here).

100

to be folded in once all `klex-git` binaries have moved here).

100

- Otherwise Go standard library only.

101

- Otherwise Go standard library only.

package main

import "encoding/json"

import "flag"

import "fmt"

import "os"

import "text/tabwriter"

import "oscarkilo.com/okg/who"

func runGroup(args []string) error {

if len(args) == 0 {

return fmt.Errorf(

"usage: okg group SUBCOMMAND ... " +

"(try `okg --help`)")

}

switch args[0] {

case "list":

return runGroupList(args[1:])

case "create":

return runGroupCreate(args[1:])

case "add-member":

return runGroupAddMember(args[1:])

default:

return fmt.Errorf(

"unknown group subcommand: %s", args[0])

}

func runGroupList(args []string) error {

fs := flag.NewFlagSet("group list", flag.ContinueOnError)

asJSON := fs.Bool("json", false, "output raw JSON")

if err := fs.Parse(args); err != nil {

return err

}

c, err := newWhoClient()

if err != nil {

return err

}

groups, err := c.ListGroups()

if err != nil {

return err

}

if *asJSON {

buf, err := json.MarshalIndent(groups, "", " ")

if err != nil {

return err

}

fmt.Println(string(buf))

return nil

}

tw := tabwriter.NewWriter(os.Stdout, 0, 2, 2, ' ', 0)

fmt.Fprintln(tw, "USERNAME\tFULL NAME\tOWNER")

for _, g := range groups {

fmt.Fprintf(tw, "%s\t%s\t%s\n",

g.Username, g.Name, g.OwnerUsername)

}

return tw.Flush()

}

func runGroupCreate(args []string) error {

fs := flag.NewFlagSet(

"group create", flag.ContinueOnError)

fullName := fs.String("full-name", "",

"display name (default: NAME)")

owner := fs.String("owner", "",

"owner username (default: caller)")

if err := fs.Parse(args); err != nil {

return err

}

positional := fs.Args()

if len(positional) != 1 {

return fmt.Errorf("usage: okg group create NAME")

}

name := positional[0]

c, err := newWhoClient()

if err != nil {

return err

}

if *owner == "" {

me, err := c.GetProfile()

if err != nil {

return fmt.Errorf("resolve caller: %v", err)

}

*owner = me.Username

}

displayName := *fullName

if displayName == "" {

displayName = name

}

if err := c.CreateGroup(who.CreateGroupRequest{

Username: name,

100

Username: name,

Name: displayName,

101

Name: displayName,

100

OwnerUsername: *owner,

102

OwnerUsername: *owner,

101

}); err != nil {

103

}); err != nil {

102

return err

104

return err

103

}

105

}

104

fmt.Printf(

106

fmt.Printf(

105

"Created group %s (owner: %s)\n", name, *owner)

107

"Created group %s (owner: %s)\n", name, *owner)

106

return nil

108

return nil

107

}

109

}

108

110

111

func runGroupAddMember(args []string) error {

112

fs := flag.NewFlagSet(

113

"group add-member", flag.ContinueOnError)

114

if err := fs.Parse(args); err != nil {

115

return err

116

}

117

positional := fs.Args()

118

if len(positional) < 2 {

119

return fmt.Errorf(

120

"usage: okg group add-member GROUP USER [USER ...]")

121

}

122

group := positional[0]

123

members := positional[1:]

124

125

c, err := newWhoClient()

126

if err != nil {

127

return err

128

}

129

if err := c.JoinGroups(who.JoinGroupsRequest{

130

GroupUsernames: []string{group},

131

MemberUsernames: members,

132

}); err != nil {

133

return err

134

}

135

fmt.Printf(

136

"Added %d member(s) to %s\n", len(members), group)

137

return nil

138

}

139

109

// newWhoClient builds a //who client from saved config. Shared

140

// newWhoClient builds a //who client from saved config. Shared

110

// by every `okg group` subcommand.

141

// by every `okg group` subcommand.

111

func newWhoClient() (*who.HTTPClient, error) {

142

func newWhoClient() (*who.HTTPClient, error) {

112

cfg, err := loadConfig()

143

cfg, err := loadConfig()

113

if err != nil {

144

if err != nil {

114

return nil, err

145

return nil, err

115

}

146

}

116

if cfg.ApiKey == "" {

147

if cfg.ApiKey == "" {

117

return nil, fmt.Errorf(

148

return nil, fmt.Errorf(

118

"no API key — run `okg auth login --key sk-...`")

149

"no API key — run `okg auth login --key sk-...`")

119

}

150

}

120

return who.NewHTTPClient(cfg.Host, cfg.ApiKey), nil

151

return who.NewHTTPClient(cfg.Host, cfg.ApiKey), nil

121

}

152

}

package main

import "fmt"

import "os"

func main() {

args := os.Args[1:]

if len(args) == 0 {

printUsage()

os.Exit(1)

}

var err error

switch args[0] {

case "pr":

err = runPR(args[1:])

case "repo":

err = runRepo(args[1:])

case "auth":

err = runAuth(args[1:])

case "embed":

err = runEmbed(args[1:])

case "one":

err = runOne(args[1:])

case "group":

err = runGroup(args[1:])

case "help", "--help", "-h":

printUsage()

return

default:

fmt.Fprintf(os.Stderr, "unknown command: %s\n", args[0])

printUsage()

os.Exit(1)

}

if err != nil {

fmt.Fprintf(os.Stderr, "error: %v\n", err)

os.Exit(1)

}

func printUsage() {

fmt.Fprintf(os.Stderr, `NAME

okg — Oscar Kilo Goodness

SETUP

okg auth login

--key KEY API key (also accepted via stdin)

--host HOST klee host (default: production)

GIT REPOS

okg repo list

--json output raw JSON

okg repo create NAME

--reader USER grant read to USER (default: anyone)

GROUPS

okg group list

--json output raw JSON

okg group create NAME

--full-name TEXT display name (default: NAME)

--owner USER owner username (default: caller)

okg group add-member GROUP USER [USER ...]

PULL REQUESTS

okg pr list

--state STATE open or closed (default: open)

--json output raw JSON

okg pr create

--head BRANCH source branch

--base BRANCH target branch (default: master)

--title TITLE PR title

--body BODY PR body (optional)

--json output raw JSON

okg pr view NUMBER

--json output raw JSON

okg pr diff NUMBER

okg pr comment NUMBER

--body BODY comment body

--approve also approve the PR

--request-changes also request changes

okg pr merge NUMBER

--json output raw JSON

okg pr close NUMBER

--json output raw JSON

okg pr reopen NUMBER

--json output raw JSON

ARTIFICIAL INTELLIGENCE

okg embed

100

okg embed

--model NAME embedding model

101

--model NAME embedding model

100

(default: openai:text-embedding-3-small)

102

(default: openai:text-embedding-3-small)

101

--dims N number of dimensions (default: 1536)

103

--dims N number of dimensions (default: 1536)

102

--full-path one vector per prefix of input

104

--full-path one vector per prefix of input

103

(reads stdin; writes vectors to stdout, one per line)

105

(reads stdin; writes vectors to stdout, one per line)

104

106

105

okg one

107

okg one

106

--model NAME override .Model in the request

108

--model NAME override .Model in the request

107

--system-file FILE override .System with contents of FILE

109

--system-file FILE override .System with contents of FILE

108

--prompt-file FILE append FILE as a user prompt

110

--prompt-file FILE append FILE as a user prompt

109

--attach FILE attach an image or PDF to the prompt

111

--attach FILE attach an image or PDF to the prompt

110

--format FORMAT text | json | jsonindent (default: text)

112

--format FORMAT text | json | jsonindent (default: text)

111

--fast-fail preflight attachment MIME (default: on)

113

--fast-fail preflight attachment MIME (default: on)

112

(reads stdin as a JSON MessagesRequest; flags override

114

(reads stdin as a JSON MessagesRequest; flags override

113

its fields)

115

its fields)

114

116

115

GLOBAL FLAGS

117

GLOBAL FLAGS

116

--repo REPO override auto-detected repo name

118

--repo REPO override auto-detected repo name

117

--json output raw JSON (where applicable)

119

--json output raw JSON (where applicable)

118

120

119

EXAMPLES

121

EXAMPLES

120

Setup

122

Setup

121

okg auth login --key sk-...

123

okg auth login --key sk-...

122

cat ~/.klex.key | okg auth login

124

cat ~/.klex.key | okg auth login

123

125

124

Git repos

126

Git repos

125

okg repo list

127

okg repo list

126

okg repo create my-new-repo

128

okg repo create my-new-repo

127

129

128

Groups

130

Groups

129

okg group list

131

okg group list

130

okg group create chat-bots

132

okg group create chat-bots

133

okg group add-member chat-bots claude openclaw

131

134

132

Pull requests

135

Pull requests

133

okg pr list --state open

136

okg pr list --state open

134

okg pr view 42

137

okg pr view 42

135

okg pr comment 42 --body 'LGTM' --approve

138

okg pr comment 42 --body 'LGTM' --approve

136

139

137

Artificial intelligence

140

Artificial intelligence

138

echo 'hello world' | okg embed --dims 384

141

echo 'hello world' | okg embed --dims 384

139

echo Hello? > /tmp/q.txt && \

142

echo Hello? > /tmp/q.txt && \

140

okg one --model openai:gpt-4o-mini --prompt-file /tmp/q.txt

143

okg one --model openai:gpt-4o-mini --prompt-file /tmp/q.txt

141

144

142

}

145

}

// Package who is the public HTTP client for OscarKilo's //who

// service. It is the world-public side of //who, used by

// `okg` and any other tool that talks to oscarkilo.com over

// the network.

// //clients/who (intra-cluster, has the in-process MockClient,

// the /internal/* calls, the dev/prod factory) will eventually

// import this package via `import . "oscarkilo.com/okg/who"`

// so the two share types and request paths. To make that dot

// import work, the struct here is named HTTPClient — leaving

// the unqualified `Client` name free for //clients/who's

// existing interface.

package who

import "oscarkilo.com/okg/internal/rest"

// HTTPClient talks to a //who server over HTTPS. Embeds the

// shared rest helpers; who-specific methods live below.

type HTTPClient struct {

*rest.Client

}

func NewHTTPClient(host, apiKey string) *HTTPClient {

return &HTTPClient{Client: rest.NewClient(host, apiKey)}

}

// ---- Caller identity ----

// Profile is the caller's //who profile. Mirrors the

// JSON-serialized subset of //who.Profile that GET

// /login/profile/get returns. Extra fields the server may

// return (ApiKeys, Logins, AppData, timestamps) are decoded

// permissively if added later; we just don't expose them here

// until okg has a use for them.

type Profile struct {

Owid string `json:"owid"`

Username string `json:"username"`

Name string `json:"name"`

Email string `json:"email"`

PortraitUrl string `json:"portrait_url"`

OwnerOwid string `json:"owner_owid"`

Groups []string `json:"groups"`

}

// GetProfile returns the caller's own profile, identified by

// the Bearer key.

func (c *HTTPClient) GetProfile() (*Profile, error) {

var p Profile

if err := c.GetJSON("/login/profile/get", &p); err != nil {

return nil, err

}

return &p, nil

}

// ---- Groups ----

// Group describes a //who group (a named entity with members).

// Mirrors the listedGroup shape in //who/server/groups_list.go.

type Group struct {

Owid string `json:"owid"`

Username string `json:"username"`

Name string `json:"name"`

OwnerOwid string `json:"owner_owid"`

OwnerUsername string `json:"owner_username"`

}

type listGroupsResponse struct {

Groups []Group `json:"groups"`

}

// ListGroups returns the groups visible to the caller.

func (c *HTTPClient) ListGroups() ([]Group, error) {

var res listGroupsResponse

if err := c.GetJSON("/groups/list", &res); err != nil {

return nil, err

}

return res.Groups, nil

}

// CreateGroupRequest is the body for POST /groups/add. Username

// is the group's //who username (e.g. "team"); Name is the

// human-facing display name; OwnerUsername is the user who'll

// own the new group.

type CreateGroupRequest struct {

Username string `json:"username"`

Name string `json:"name"`

OwnerUsername string `json:"owner_username"`

}

// CreateGroup creates a new //who group.

func (c *HTTPClient) CreateGroup(req CreateGroupRequest) error {

return c.PostJSON("/groups/add", req, nil)

}

// JoinGroupsRequest is the body for POST /groups/join. The

// server adds every (GroupUsernames[i], MemberUsernames[j])

// pair, requiring the caller to be an owner of each group.

type JoinGroupsRequest struct {

GroupUsernames []string `json:"group_usernames"`

100

MemberUsernames []string `json:"member_usernames"`

101

}

102

103

// JoinGroups adds members to groups (all pairwise combinations).

104

func (c *HTTPClient) JoinGroups(req JoinGroupsRequest) error {

105

return c.PostJSON("/groups/join", req, nil)

106

}

package who

import "encoding/json"

import "net/http"

import "net/http/httptest"

import "testing"

func TestListGroups(t *testing.T) {

srv := httptest.NewServer(http.HandlerFunc(

func(w http.ResponseWriter, r *http.Request) {

if r.URL.Path != "/groups/list" {

t.Errorf("path: got %q, want /groups/list",

r.URL.Path)

}

if r.Header.Get("Authorization") !=

"Bearer test-key" {

t.Errorf("Authorization: got %q",

r.Header.Get("Authorization"))

}

w.Header().Set(

"Content-Type", "application/json")

json.NewEncoder(w).Encode(listGroupsResponse{

Groups: []Group{

{

Username: "team",

Name: "Team",

OwnerUsername: "alice",

{

Username: "admins",

Name: "Admins",

OwnerUsername: "alice",

})

}))

defer srv.Close()

c := NewHTTPClient(srv.URL, "test-key")

groups, err := c.ListGroups()

if err != nil {

t.Fatal(err)

}

if len(groups) != 2 {

t.Fatalf("len: got %d, want 2", len(groups))

}

if groups[0].Username != "team" {

t.Errorf(

"groups[0].Username: got %q, want team",

groups[0].Username)

}

if groups[1].OwnerUsername != "alice" {

t.Errorf(

"groups[1].OwnerUsername: got %q, want alice",

groups[1].OwnerUsername)

}

func TestListGroupsHTTPError(t *testing.T) {

srv := httptest.NewServer(http.HandlerFunc(

func(w http.ResponseWriter, r *http.Request) {

w.WriteHeader(401)

w.Write([]byte("not authenticated"))

}))

defer srv.Close()

c := NewHTTPClient(srv.URL, "bad-key")

_, err := c.ListGroups()

if err == nil {

t.Fatal("want error on 401, got nil")

}

func TestGetProfile(t *testing.T) {

srv := httptest.NewServer(http.HandlerFunc(

func(w http.ResponseWriter, r *http.Request) {

if r.URL.Path != "/login/profile/get" {

t.Errorf(

"path: got %q, want /login/profile/get",

r.URL.Path)

}

w.Header().Set(

"Content-Type", "application/json")

json.NewEncoder(w).Encode(Profile{

Username: "alice",

Name: "Alice Liddell",

Email: "[email protected]",

Groups: []string{"team", "admins"},

})

}))

defer srv.Close()

c := NewHTTPClient(srv.URL, "test-key")

p, err := c.GetProfile()

if err != nil {

t.Fatal(err)

}

if p.Username != "alice" {

t.Errorf(

100

"Username: got %q, want alice", p.Username)

100

"Username: got %q, want alice", p.Username)

101

}

101

}

102

if len(p.Groups) != 2 {

102

if len(p.Groups) != 2 {

103

t.Errorf(

103

t.Errorf(

104

"Groups: got %d, want 2", len(p.Groups))

104

"Groups: got %d, want 2", len(p.Groups))

105

}

105

}

106

}

106

}

107

108

func TestCreateGroup(t *testing.T) {

108

func TestCreateGroup(t *testing.T) {

109

var seen CreateGroupRequest

109

var seen CreateGroupRequest

110

srv := httptest.NewServer(http.HandlerFunc(

110

srv := httptest.NewServer(http.HandlerFunc(

111

func(w http.ResponseWriter, r *http.Request) {

111

func(w http.ResponseWriter, r *http.Request) {

112

if r.URL.Path != "/groups/add" {

112

if r.URL.Path != "/groups/add" {

113

t.Errorf(

113

t.Errorf(

114

"path: got %q, want /groups/add",

114

"path: got %q, want /groups/add",

115

r.URL.Path)

115

r.URL.Path)

116

}

116

}

117

if r.Method != "POST" {

117

if r.Method != "POST" {

118

t.Errorf("method: got %q, want POST", r.Method)

118

t.Errorf("method: got %q, want POST", r.Method)

119

}

119

}

120

json.NewDecoder(r.Body).Decode(&seen)

120

json.NewDecoder(r.Body).Decode(&seen)

121

w.WriteHeader(200)

121

w.WriteHeader(200)

122

}))

122

}))

123

defer srv.Close()

123

defer srv.Close()

124

125

c := NewHTTPClient(srv.URL, "test-key")

125

c := NewHTTPClient(srv.URL, "test-key")

126

err := c.CreateGroup(CreateGroupRequest{

126

err := c.CreateGroup(CreateGroupRequest{

127

Username: "team",

127

Username: "team",

128

Name: "Team",

128

Name: "Team",

129

OwnerUsername: "alice",

129

OwnerUsername: "alice",

130

})

130

})

131

if err != nil {

131

if err != nil {

132

t.Fatal(err)

132

t.Fatal(err)

133

}

133

}

134

if seen.Username != "team" {

134

if seen.Username != "team" {

135

t.Errorf(

135

t.Errorf(

136

"Username: got %q, want team", seen.Username)

136

"Username: got %q, want team", seen.Username)

137

}

137

}

138

if seen.OwnerUsername != "alice" {

138

if seen.OwnerUsername != "alice" {

139

t.Errorf(

139

t.Errorf(

140

"OwnerUsername: got %q, want alice",

140

"OwnerUsername: got %q, want alice",

141

seen.OwnerUsername)

141

seen.OwnerUsername)

142

}

142

}

143

}

143

}

144

145

func TestJoinGroups(t *testing.T) {

146

var seen JoinGroupsRequest

147

srv := httptest.NewServer(http.HandlerFunc(

148

func(w http.ResponseWriter, r *http.Request) {

149

if r.URL.Path != "/groups/join" {

150

t.Errorf(

151

"path: got %q, want /groups/join",

152

r.URL.Path)

153

}

154

if r.Method != "POST" {

155

t.Errorf("method: got %q, want POST", r.Method)

156

}

157

json.NewDecoder(r.Body).Decode(&seen)

158

w.WriteHeader(200)

159

}))

160

defer srv.Close()

161

162

c := NewHTTPClient(srv.URL, "test-key")

163

err := c.JoinGroups(JoinGroupsRequest{

164

GroupUsernames: []string{"team"},

165

MemberUsernames: []string{"alice", "bob"},

166

})

167

if err != nil {

168

t.Fatal(err)

169

}

170

if len(seen.GroupUsernames) != 1 ||

171

seen.GroupUsernames[0] != "team" {

172

t.Errorf(

173

"GroupUsernames: got %v, want [team]",

174

seen.GroupUsernames)

175

}

176

if len(seen.MemberUsernames) != 2 {

177

t.Errorf(

178

"MemberUsernames: got %v, want 2 members",

179

seen.MemberUsernames)

180

}

181

}