docker-archive
diff --git a/‎cmd/infrakit/main.go
Lines changed: 1 addition & 0 deletions b/‎cmd/infrakit/main.go
Lines changed: 1 addition & 0 deletions
diff --git a/‎pkg/provider/oracle/client/README.md
Lines changed: 101 additions & 0 deletions b/‎pkg/provider/oracle/client/README.md
Lines changed: 101 additions & 0 deletions
diff --git a/‎pkg/provider/oracle/client/api/client.go
Lines changed: 129 additions & 0 deletions b/‎pkg/provider/oracle/client/api/client.go
Lines changed: 129 additions & 0 deletions
diff --git a/‎pkg/provider/oracle/client/api/http_client.go
Lines changed: 88 additions & 0 deletions b/‎pkg/provider/oracle/client/api/http_client.go
Lines changed: 88 additions & 0 deletions
@@ -56,6 +56,7 @@ import (
 	_ "github.com/docker/infrakit/pkg/run/v0/libvirt"
 	_ "github.com/docker/infrakit/pkg/run/v0/maas"
 	_ "github.com/docker/infrakit/pkg/run/v0/manager"
+	_ "github.com/docker/infrakit/pkg/run/v0/oracle"
 	_ "github.com/docker/infrakit/pkg/run/v0/packet"
 	_ "github.com/docker/infrakit/pkg/run/v0/rackhd"
 	_ "github.com/docker/infrakit/pkg/run/v0/selector"
 
@@ -0,0 +1,101 @@
+# Oracle BMC Golang SDK
+
+[![GoDoc](https://godoc.org/github.com/FrenchBen/oracle-sdk-go?status.svg)](https://godoc.org/github.com/FrenchBen/oracle-sdk-go)
+[![MIT licensed](https://img.shields.io/badge/license-MIT-blue.svg)](https://raw.githubusercontent.com/FrenchBen/oracle-sdk-go/master/LICENSE)
+[![TravisCI](https://travis-ci.org/FrenchBen/oracle-sdk-go.svg?branch=master)](https://travis-ci.org/FrenchBen/oracle-sdk-go)
+[![Go Report Card](https://goreportcard.com/badge/github.com/FrenchBen/oracle-sdk-go)](https://goreportcard.com/report/github.com/FrenchBen/oracle-sdk-go)
+[![Badge Badge](http://doyouevenbadge.com/github.com/FrenchBen/oracle-sdk-go)](http://doyouevenbadge.com)
+
+Unofficial Oracle Bare Metal Cloud Golang SDK
+
+
+
+<p align="center">
+  <a href="http://golang.org" target="_blank"><img alt="Go package" src="https://golang.org/doc/gopher/pencil/gopherhat.jpg" width="20%" /></a>
+</p>
+<p align="center">
+  <img src="https://cdn4.iconfinder.com/data/icons/linecon/512/add-128.png" alt="plus" />
+</p>
+<p align="center">
+  <a href="https://www.oraclecloud.com/" target="_blank"><img src="https://static1.squarespace.com/static/587d94cf4402432706cdd02d/t/58cee1bd1b10e37dbd70b243/1489953226294/oracle-logo" alt="Oracle Cloud Logo"/></a>
+</p>
+
+
+
+
+## Requirements
+The following variables are needed in order to make successful calls to the BMC API
+
+* User - The user for the compartment
+```
+user=ocid1.user.oc1..aaaaaaaat5nvwcna5j6aqzjcaty5eqbb6qt2jvpkanghtgdaqedqw3rynjq
+```
+* Fingerprint - The API key fingerprint; this fingerprint can be found within the Oracle BMC console
+```
+fingerprint=20:3b:97:13:55:1c:5b:0d:d3:37:d8:50:4e:c5:3a:34
+```
+* KeyFile - The API key file location
+```
+key_file=~/.oraclebmc/bmcs_api_key.pem
+```
+* Tenancy - Your tenancy compartment ID
+```
+tenancy=ocid1.tenancy.oc1..aaaaaaaaba3pv6wkcr4jqae5f15p2b2m2yt2j6rx32uzr4h25vqstifsfdsq
+```
+* Region - The region corresponding to the compartment in use
+```
+region=us-ashburn-1
+```
+
+A default config file can also be used; the typical location for the Oracle BMC config is: `~/.oraclebmc/config`
+The config file should have the following format:
+```
+[DEFAULT]
+  user=ocid1.user.oc1..aaaaaaaat5nvwcna5j6aqzjcaty5eqbb6qt2jvpkanghtgdaqedqw3rynjq
+  fingerprint=20:3b:97:13:55:1c:5b:0d:d3:37:d8:50:4e:c5:3a:34
+  key_file=~/.oraclebmc/bmcs_api_key.pem
+  tenancy=ocid1.tenancy.oc1..aaaaaaaaba3pv6wkcr4jqae5f15p2b2m2yt2j6rx32uzr4h25vqstifsfdsq
+  region=us-ashburn-1
+```
+
+# Support Endpoint
+
+The following endpoints are provided by the [Oracle BMC API](https://docs.us-phoenix-1.oraclecloud.com/api/)
+
+| Name | Support |
+| --- | --- |
+| Audit API | NO |
+| Database Service API | NO |
+| Core Services API | YES-partial |
+| Identity and Access Management Service API | NO |
+| Load Balancing Service API | YES-partial |
+| Object Storage Service API | NO |
+| S3 Object Storage Service API | NO |
+
+Only API supported at the moment is to get instance details
+* List instances
+* Get instance
+* List VNIC
+* Get VNIC
+* List VNICAttachment
+* Get VNICAttachment
+* List SecurityList
+* Get SecurityList
+* Create SecurityList
+* Update SecurityList
+* Delete SecurityList
+* List VirtualCloudNetwork
+* Get VirtualCloudNetwork
+* List Backend
+* Get Backend
+* Create Backend
+* Delete Backend
+* List BackendSet
+* Get BackendSet
+* Create BackendSet
+* Delete BackendSet
+* Create Listener
+* Delete Listener
+* List LoadBalancer
+* Get LoadBalancer
+
@@ -0,0 +1,129 @@
+package api
+
+import (
+	"crypto/rsa"
+	"encoding/json"
+	"fmt"
+	"io/ioutil"
+	"log"
+	"net/http"
+	"path/filepath"
+	"time"
+
+	"github.com/Sirupsen/logrus"
+	"github.com/docker/infrakit/pkg/provider/oracle/client/bmc"
+	"golang.org/x/crypto/ssh"
+)
+
+const (
+	// EndpointFormat provides the base template for all API url
+	EndpointFormat = "https://iaas.%s.oraclecloud.com/%s/"
+	// CoreAPIVersion is the API version for core services
+	CoreAPIVersion = "20160918"
+	// LoadBalancerAPIVersion is the API version for load balancing services
+	LoadBalancerAPIVersion = "20170115"
+	metaDataURL            = "http://169.254.169.254/opc/v1/instance/"
+)
+
+// Config holds the general API bmcConf
+type config struct {
+}
+
+// Client represents the struct for basic api calls
+type Client struct {
+	apiKey        string
+	apiPrivateKey *rsa.PrivateKey
+	APIRegion     string
+	httpClient    *http.Client
+}
+
+type metaData struct {
+	AvailabilityDomain string `json:"availabilityDomain"`
+	CompartmentID      string `json:"compartmentId"`
+	DisplayName        string `json:"displayName"`
+	ID                 string `json:"id"`
+	Image              string `json:"image"`
+	Metadata           struct {
+		PublicKey string `json:"ssh_authorized_keys"`
+		UserData  string `json:"user_data"`
+	} `json:"metadata"`
+	Region      string `json:"region"`
+	Shape       string `json:"shape"`
+	State       string `json:"state"`
+	TimeCreated string `json:"timeCreated"`
+}
+
+// NewClient creates a new, unauthenticated compute Client.
+func NewClient(bmcConf *bmc.Config) (*Client, error) {
+	apiKey := fmt.Sprintf("%s/%s/%s", *bmcConf.Tenancy, *bmcConf.User, *bmcConf.Fingerprint)
+	logrus.Debug("Api Key: ", apiKey)
+	privateKey, err := loadKeyFromFile(bmcConf.KeyFile, bmcConf.PassPhrase)
+	if err != nil {
+		// If we failed to read the file because the key does not exist,
+		// just issue a warning and continue.
+		logrus.Error("private key error: ", err)
+		return nil, err
+	}
+
+	return &Client{
+		apiKey:        apiKey,
+		apiPrivateKey: privateKey,
+		APIRegion:     getRegion(bmcConf),
+		httpClient: &http.Client{
+			Transport: &http.Transport{
+				Proxy:               http.ProxyFromEnvironment,
+				TLSHandshakeTimeout: 120 * time.Second},
+		},
+	}, nil
+}
+
+// only load keys that have no password for now :(
+func loadKeyFromFile(pemFile *string, passphrase *string) (*rsa.PrivateKey, error) {
+	pemPath, err := filepath.Abs(*pemFile)
+	logrus.Debugf("Loading key file from: %s - %s", *pemFile, pemPath)
+	if err != nil {
+		logrus.Errorf("KeyFile error: %s", err)
+		return nil, err
+	}
+	pemBytes, err := ioutil.ReadFile(pemPath)
+	if err != nil {
+		return nil, err
+	}
+	// check if a passphrase was given
+	var rawKey interface{}
+	if passphrase != nil {
+		rawKey, err = ssh.ParseRawPrivateKeyWithPassphrase(pemBytes, []byte(*passphrase))
+	} else {
+		rawKey, err = ssh.ParseRawPrivateKey(pemBytes)
+	}
+	if err != nil {
+		logrus.Errorf("Cannot parse private key: %s", err)
+	}
+	rsaKey, ok := rawKey.(*rsa.PrivateKey)
+	if !ok {
+		logrus.Fatalf("Could not create private key: %v", rawKey)
+		return nil, err
+	}
+	return rsaKey, err
+}
+
+func getRegion(bmcConf *bmc.Config) string {
+	if bmcConf.Region != nil {
+		return *bmcConf.Region
+	}
+	res, err := http.Get(metaDataURL)
+	if err != nil {
+		log.Fatalf("Error getting metadata: %s", err)
+	}
+	defer res.Body.Close()
+	body, err := ioutil.ReadAll(res.Body)
+	if err != nil {
+		log.Fatal(err)
+	}
+	var meta = new(metaData)
+	err = json.Unmarshal(body, &meta)
+	if err != nil {
+		log.Fatalf("Error parsing JSON: %s", err)
+	}
+	return meta.Region
+}
@@ -0,0 +1,88 @@
+package api
+
+import (
+	"bytes"
+	"crypto/sha256"
+	"encoding/base64"
+	"encoding/json"
+	"io"
+	"net/http"
+	"net/url"
+	"strconv"
+	"strings"
+	"time"
+
+	"github.com/Sirupsen/logrus"
+	"github.com/spacemonkeygo/httpsig"
+)
+
+// Signing details: https://docs.us-phoenix-1.oraclecloud.com/Content/API/Concepts/signingrequests.htm
+
+var headersConst = []string{"date", "(request-target)", "host"}
+
+// Clienter is the client interface for all requests
+type Clienter interface {
+	Request(string, string, interface{}) (*http.Response, error)
+}
+
+func (c *Client) signAuthHeader(req *http.Request, body []byte) {
+	// Add missing defaults
+	if req.Header.Get("Content-Type") == "" {
+		req.Header.Set("Content-Type", "application/json")
+	}
+	if req.Header.Get("Host") == "" {
+		req.Header.Set("Host", req.URL.Hostname())
+	}
+	if req.Header.Get("Date") == "" {
+		t := time.Now()
+		req.Header.Set("Date", t.Format(time.RFC1123))
+	}
+	headersToSign := headersConst
+	if strings.HasPrefix(req.Method, "P") {
+
+		headersToSign = append(headersConst, "x-content-sha256", "content-type", "content-length")
+		bodyHash := sha256.Sum256(body)
+		req.Header.Set("Content-Length", strconv.Itoa(len(body)))
+		req.Header.Set("X-Content-Sha256", base64.StdEncoding.EncodeToString(bodyHash[:]))
+	}
+
+	signer := httpsig.NewRSASHA256Signer(c.apiKey, c.apiPrivateKey, headersToSign)
+	err := signer.Sign(req)
+	if err != nil {
+		logrus.Fatalf("Could not sign request: %s", err)
+	}
+
+	return
+}
+
+// Request request a resource from Oracle
+func (c *Client) Request(method string, reqURL string, body interface{}) (*http.Response, error) {
+	// Parse URL Path
+	urlPath, err := url.Parse(reqURL)
+	if err != nil {
+		return nil, err
+	}
+
+	// Marshall request body
+	var requestBody io.ReadSeeker
+	var marshaled []byte
+	if body != nil {
+		marshaled, err = json.Marshal(body)
+		logrus.Debug("Body: ", string(marshaled))
+		if err != nil {
+			return nil, err
+		}
+		requestBody = bytes.NewReader(marshaled)
+	}
+
+	// Create Request
+	req, err := http.NewRequest(method, urlPath.String(), requestBody)
+	if err != nil {
+		return nil, err
+	}
+
+	c.signAuthHeader(req, marshaled)
+	logrus.Debug("Auth: ", req.Header)
+	logrus.Debug("Request URL: ", req.URL.String(), " Method: ", method)
+	return c.httpClient.Do(req)
+}