Merge pull request #959 from Vafilor/feat/create.namespace.stub

feat: stub out create namespace

Dockerfile

@@ -12,6 +12,7 @@ FROM golang:1.15.5
 COPY --from=builder /go/bin/core .
 COPY --from=builder /go/src/db ./db
 COPY --from=builder /go/bin/goose .
+COPY --from=builder /go/src/manifest ./manifest
 
 EXPOSE 8888
 EXPOSE 8887

api/api.swagger.json

@@ -3,7 +3,7 @@
  "info": {
  "title": "Onepanel",
  "description": "Onepanel API",
- "version": "1.0.0",
+ "version": "1.0.2",
  "contact": {
  "name": "Onepanel project",
  "url": "https:/onepanelio/core"
@@ -4184,6 +4184,9 @@
  "properties": {
  "name": {
  "type": "string"
+ },
+ "sourceName": {
+ "type": "string"
  }
  }
  },

api/proto/namespace.proto

@@ -40,4 +40,5 @@ message CreateNamespaceRequest {
 
 message Namespace {
  string name = 1;
+ string sourceName = 2;
 }

pkg/config_types.go

@@ -174,6 +174,11 @@ func (s SystemConfig) DatabaseDriverName() *string {
  return s.GetValue("databaseDriverName")
 }
 
+// Provider gets the ONEPANEL_PROVIDER value, or nil.
+func (s SystemConfig) Provider() *string {
+ return s.GetValue("ONEPANEL_PROVIDER")
+}
+
 // DatabaseConnection returns system config information to connect to a database
 func (s SystemConfig) DatabaseConnection() (driverName, dataSourceName string) {
  dataSourceName = fmt.Sprintf("host=%v user=%v password=%v dbname=%v sslmode=disable",
@@ -243,6 +248,7 @@ func (s SystemConfig) HMACKey() []byte {
 // by the CLI. CLI will marshal this struct into the correct
 // YAML structure for k8s configmap / secret.
 type ArtifactRepositoryS3Provider struct {
+ Source string
  KeyFormat string `yaml:"keyFormat"`
  Bucket string
  Endpoint string
@@ -260,6 +266,7 @@ type ArtifactRepositoryS3Provider struct {
 // by the CLI. CLI will marshal this struct into the correct
 // YAML structure for k8s configmap / secret.
 type ArtifactRepositoryGCSProvider struct {
+ Source string
  KeyFormat string `yaml:"keyFormat"`
  Bucket string
  Endpoint string

pkg/istio.go

@@ -0,0 +1,43 @@
+package v1
+
+import (
+ "fmt"
+ "github.com/onepanelio/core/pkg/util"
+ "google.golang.org/grpc/codes"
+ "k8s.io/apimachinery/pkg/runtime/schema"
+ "k8s.io/client-go/kubernetes/scheme"
+ "k8s.io/client-go/rest"
+ "strings"
+)
+
+const istioVirtualServiceResource = "VirtualServices"
+
+func istioModelRestClient() (*rest.RESTClient, error) {
+ config := *NewConfig()
+ config.GroupVersion = &schema.GroupVersion{Group: "networking.istio.io", Version: "v1alpha3"}
+ config.APIPath = "/apis"
+ config.NegotiatedSerializer = scheme.Codecs.WithoutConversion()
+
+ return rest.RESTClientFor(&config)
+}
+
+// CreateVirtualService creates an istio virtual service
+func (c *Client) CreateVirtualService(namespace string, data interface{}) error {
+ restClient, err := istioModelRestClient()
+ if err != nil {
+ return err
+ }
+
+ err = restClient.Post().
+ Namespace(namespace).
+ Resource(istioVirtualServiceResource).
+ Body(data).
+ Do().
+ Error()
+
+ if err != nil && strings.Contains(err.Error(), "already exists") {
+ return util.NewUserError(codes.AlreadyExists, fmt.Sprintf("VirtualService already exists"))
+ }
+
+ return err
+}