user.go

package kiicli

import (
	"fmt"
	"io"
	"os"
	"path"
	"strings"

	"github.com/tmtk75/cli"
)

type UserCreationRequest struct {
	LoginName string `json:"loginName"`
	Password  string `json:"password"`
}

func CreateUser(loginname string, password string) {
	p := Profile()
	path := fmt.Sprintf("/apps/%s/users", p.AppId)
	headers := p.HttpHeaders("application/json")
	req := &UserCreationRequest{loginname, password}
	res := HttpPostJson(path, headers, req)
	defer res.Body.Close()
	io.Copy(os.Stdout, res.Body)
}

func LoginAsUser(username string, password string) {
	p := Profile()
	dir := path.Join(p.AppId, username)
	tokenPath := metaFilePath(dir, "token")

	oauth2res := &OAuth2Response{}
	if b, _ := exists(tokenPath); b {
		oauth2res.LoadFrom(tokenPath)
	} else {
		headers := p.HttpHeaders("application/json")
		req := map[string]string{"username": username, "password": password}
		res := HttpPostJson("/oauth2/token", headers, req)
		oauth2res.Decode(res)
		oauth2res.Save(tokenPath)
	}

	fmt.Println(oauth2res)
}

func ReadUser(userId string) {
	p := Profile()
	path := fmt.Sprintf("/apps/%s/users/%v", p.AppId, userId)
	headers := p.HttpHeadersWithAuthorization("application/json")
	b := HttpGet(path, headers).Bytes()
	fmt.Println(string(b))
}

func ListUsers() {
	p := Profile()
	path := fmt.Sprintf("/apps/%s/users/query", p.AppId)
	headers := p.HttpHeadersWithAuthorization("application/vnd.kii.userqueryrequest+json")
	body := strings.NewReader(`{"userQuery":{"clause":{"type":"all"}}}`)
	b := HttpPost(path, headers, body).Bytes()
	fmt.Println(string(b))
}

func DeleteUser(userId string) {
	p := Profile()
	path := fmt.Sprintf("/apps/%s/users/%v", p.AppId, userId)
	headers := p.HttpHeadersWithAuthorization("")
	b := HttpDelete(path, headers).Bytes()
	fmt.Println(string(b))
}

var UserCommands = []cli.Command{
	{
		Name:  "create",
		Usage: "Create a user",
		Args:  `<loginname> <password>`,
		Action: func(c *cli.Context) {
			name, _ := c.ArgFor("loginname")
			pass, _ := c.ArgFor("password")
			CreateUser(name, pass)
		},
	},
	{
		Name:  "read",
		Usage: "Read a user",
		Args:  `<user-id>`,
		Action: func(c *cli.Context) {
			uid, _ := c.ArgFor("user-id")
			ReadUser(uid)
		},
	},
	{
		Name:  "list",
		Usage: "List users",
		Action: func(c *cli.Context) {
			ListUsers()
		},
	},
	{
		Name:  "delete",
		Usage: "Delete a user",
		Args:  `<user-id>`,
		Action: func(c *cli.Context) {
			uid, _ := c.ArgFor("user-id")
			DeleteUser(uid)
		},
	},
	{
		Name:  "login",
		Usage: "Login as a user",
		Args:  `<loginname> <password>`,
		Action: func(c *cli.Context) {
			name, _ := c.ArgFor("loginname")
			pass, _ := c.ArgFor("password")
			LoginAsUser(name, pass)
		},
	},
}