Initial commit

Rudiments of how we are going to interact with the API, write
responses, etc. A lot still to be flushed out, the API should be
treated as experimental, etc.

Author: kevinburke

LICENSE

@@ -0,0 +1,50 @@
+Copyright 2019 Meter, Inc.
+
+Permission is hereby granted, free of charge, to any person obtaining a copy
+of this software and associated documentation files (the "Software"), to deal
+in the Software without restriction, including without limitation the rights
+to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
+copies of the Software, and to permit persons to whom the Software is
+furnished to do so, subject to the following conditions:
+
+The above copyright notice and this permission notice shall be included in all
+copies or substantial portions of the Software.
+
+THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
+IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
+FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
+AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
+LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
+OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE
+SOFTWARE.
+
+This project is based in part off of src/crypto/tls/generate_cert.go, a file
+available in the Go source code. The license for that file is available here:
+
+Copyright (c) 2009 The Go Authors. All rights reserved.
+
+Redistribution and use in source and binary forms, with or without
+modification, are permitted provided that the following conditions are
+met:
+
+   * Redistributions of source code must retain the above copyright
+notice, this list of conditions and the following disclaimer.
+   * Redistributions in binary form must reproduce the above
+copyright notice, this list of conditions and the following disclaimer
+in the documentation and/or other materials provided with the
+distribution.
+   * Neither the name of Google Inc. nor the names of its
+contributors may be used to endorse or promote products derived from
+this software without specific prior written permission.
+
+THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS
+"AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT
+LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR
+A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT
+OWNER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL,
+SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT
+LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE,
+DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY
+THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
+(INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE
+OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.

chat.go

@@ -0,0 +1,25 @@
+package slack
+
+import (
+	"context"
+	"net/url"
+)
+
+type ChatService struct {
+	client *Client
+}
+
+type response struct {
+	OK      bool      `json:"ok"`
+	Channel string    `json:"channel"`
+	TS      SlackTime `json:"ts"`
+	Error   string    `json:"error"`
+	Warning string    `json:"warning"`
+}
+
+// https://api.slack.com/methods/chat.postMessage
+func (c *ChatService) PostMessage(ctx context.Context, data url.Values) (*response, error) {
+	resp := new(response)
+	err := c.client.CreateResource(ctx, "/api/chat.postMessage", data, resp)
+	return resp, err
+}

chat_test.go

@@ -0,0 +1,32 @@
+package slack
+
+import (
+	"context"
+	"fmt"
+	"net/url"
+	"os"
+	"testing"
+)
+
+func TestPostMessage(t *testing.T) {
+	t.Skip("goes over the network")
+	client := New(os.Getenv("SLACK_TOKEN"))
+	users, err := client.Users.List(context.Background(), nil)
+	if err != nil {
+		t.Fatal(err)
+	}
+	var kevinuser string
+	for _, u := range users.Members {
+		if u.Name == "kevin" {
+			kevinuser = u.ID
+		}
+	}
+	resp, err := client.Chat.PostMessage(context.Background(), url.Values{
+		"channel": []string{kevinuser},
+		"text":    []string{"Hello from meterbot"},
+	})
+	if err != nil {
+		t.Fatal(err)
+	}
+	fmt.Printf("resp: %#v\n", resp)
+}

conversations.go

@@ -0,0 +1,5 @@
+package slack
+
+type ConversationService struct {
+	client *Client
+}

http.go

@@ -0,0 +1,71 @@
+package slack
+
+import (
+	"context"
+	"fmt"
+	"net/url"
+	"strings"
+
+	"github.com/kevinburke/rest"
+)
+
+const Version = "0.1"
+
+var userAgent string
+
+func init() {
+	userAgent = fmt.Sprintf("slack-go/%s", Version)
+}
+
+func New(token string) *Client {
+	restClient := rest.NewBearerClient(token, baseURL)
+	restClient.UploadType = rest.FormURLEncoded
+	c := &Client{
+		Client:  restClient,
+		baseURL: baseURL,
+	}
+	c.Chat = &ChatService{client: c}
+	c.Users = &UserService{client: c}
+	return c
+}
+
+const baseURL = "https://api.slack.com"
+
+type Client struct {
+	*rest.Client
+	baseURL string
+
+	Chat  *ChatService
+	Users *UserService
+}
+
+// CreateResource makes a POST request to the given resource.
+func (c *Client) CreateResource(ctx context.Context, pathPart string, data url.Values, v interface{}) error {
+	return c.MakeRequest(ctx, "POST", pathPart, data, v)
+}
+
+func (c *Client) ListResource(ctx context.Context, pathPart string, data url.Values, v interface{}) error {
+	return c.MakeRequest(ctx, "GET", pathPart, data, v)
+}
+
+// Make a request to the Slack API.
+func (c *Client) MakeRequest(ctx context.Context, method string, pathPart string, data url.Values, v interface{}) error {
+	rb := new(strings.Reader)
+	if data != nil && (method == "POST" || method == "PUT") {
+		rb = strings.NewReader(data.Encode())
+	}
+	if method == "GET" && data != nil {
+		pathPart = pathPart + "?" + data.Encode()
+	}
+	req, err := c.NewRequest(method, pathPart, rb)
+	if err != nil {
+		return err
+	}
+	req = req.WithContext(ctx)
+	if ua := req.Header.Get("User-Agent"); ua == "" {
+		req.Header.Set("User-Agent", userAgent)
+	} else {
+		req.Header.Set("User-Agent", userAgent+" "+ua)
+	}
+	return c.Do(req, &v)
+}

types.go

@@ -0,0 +1,32 @@
+package slack
+
+import (
+	"encoding/json"
+	"math"
+	"strconv"
+	"time"
+)
+
+type SlackTime time.Time
+
+func (s *SlackTime) UnmarshalJSON(data []byte) error {
+	var f float64
+	var ss string
+	err := json.Unmarshal(data, &ss)
+	if err == nil {
+		f, err = strconv.ParseFloat(ss, 64)
+		if err != nil {
+			return err
+		}
+	} else if err := json.Unmarshal(data, &f); err != nil {
+		return err
+	}
+	intpart, divpart := math.Modf(f)
+	*s = SlackTime(time.Unix(int64(intpart), int64(divpart*100*1000*1000)))
+	return nil
+}
+
+func (s SlackTime) MarshalJSON() ([]byte, error) {
+	ts := float64(time.Time(s).Unix()) + float64(time.Time(s).UnixNano())/100*1000*1000
+	return json.Marshal(ts)
+}

users.go

@@ -0,0 +1,26 @@
+package slack
+
+import (
+	"context"
+	"net/url"
+)
+
+type UserService struct {
+	client *Client
+}
+
+type User struct {
+	ID      string    `json:"id"`
+	Name    string    `json:"name"`
+	Updated SlackTime `json:"updated"`
+}
+
+type UsersListResponse struct {
+	Members []*User `json:"members"`
+}
+
+func (u *UserService) List(ctx context.Context, data url.Values) (*UsersListResponse, error) {
+	resp := new(UsersListResponse)
+	err := u.client.ListResource(ctx, "/api/users.list", data, resp)
+	return resp, err
+}