test/sdks_test.go

   1 /*
   2  * Copyright (C) 2017-2018 "IoT.bzh"
   3  * Author Clément Bénier <clement.benier@iot.bzh>
   4  *
   5  * Licensed under the Apache License, Version 2.0 (the "License");
   6  * you may not use this file except in compliance with the License.
   7  * You may obtain a copy of the License at
   8  *
   9  *   http://www.apache.org/licenses/LICENSE-2.0
  10  *
  11  * Unless required by applicable law or agreed to in writing, software
  12  * distributed under the License is distributed on an "AS IS" BASIS,
  13  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  14  * See the License for the specific language governing permissions and
  15  * limitations under the License.
  16  */
  17 package xdsservertest
  18
  19 import (
  20         "os"
  21         "path"
  22         "regexp"
  23         "testing"
  24         "time"
  25
  26         "gerrit.automotivelinux.org/gerrit/src/xds/xds-server/lib/xsapiv1"
  27         "github.com/stretchr/testify/assert"
  28 )
  29
  30 func ConnectSDKStateChange(t *testing.T, sCli *IOSockClient, channel chan xsapiv1.SDK) {
  31
  32         sCli.Conn.On(xsapiv1.EVTSDKStateChange, func(e xsapiv1.EventMsg) {
  33                 sdk, _ := e.DecodeSDKEvent()
  34                 channel <- sdk
  35         })
  36
  37         args := xsapiv1.EventRegisterArgs{Name: xsapiv1.EVTSDKStateChange}
  38         assert.Nil(t, HTTPCli.Post("/events/register", args, nil))
  39 }
  40
  41 func TestSdks(t *testing.T) {
  42         var sdkArray []xsapiv1.SDK
  43         assert.Nil(t, HTTPCli.Get("/sdks", &sdkArray))
  44         _, err := os.Stat(path.Join(sdkDir, "sdks_latest.json"))
  45         assert.Nil(t, err)
  46         t.Logf("Connect websocket with url=%v clientId=%v\n", prefixURL, HTTPCli.GetClientID())
  47
  48         chSdks := make(chan xsapiv1.SDK)
  49         defer close(chSdks)
  50         ConnectSDKStateChange(t, sCli, chSdks)
  51
  52         for i := 0; i < len(sdkArray); i++ {
  53                 re := regexp.MustCompile("^[0-9a-z]+-[0-9a-z]+-[0-9a-z]+-[0-9a-z]+-[0-9a-z]+$")
  54                 assert.True(t, re.MatchString(sdkArray[i].ID))
  55                 assert.Equal(t, sdkArray[0].Status, "Not Installed")
  56
  57                 var sdk xsapiv1.SDK
  58                 assert.Nil(t, HTTPCli.Get("/sdks/"+sdkArray[i].ID, &sdk))
  59                 assert.Equal(t, sdkArray[i], sdk)
  60
  61                 var sdkRes xsapiv1.SDK
  62                 assert.Nil(t, HTTPCli.Post("/sdks", sdk, &sdkRes))
  63                 assert.Equal(t, sdkRes.Status, "Installing")
  64                 time.Sleep(1 * time.Millisecond)
  65                 assert.Nil(t, HTTPCli.Post("/sdks/abortinstall", sdk, &sdkRes))
  66                 assert.Equal(t, sdkRes.Status, "Not Installed")
  67                 time.Sleep(1 * time.Millisecond)
  68                 sdkFromEvent := <-chSdks
  69                 assert.Equal(t, sdkRes.ID, sdkFromEvent.ID)
  70                 assert.Equal(t, sdkRes.Status, sdkFromEvent.Status)
  71         }
  72 }
  73
  74 func installFakeSdk(t *testing.T, sdkInstall xsapiv1.SDKInstallArgs, chSdks chan xsapiv1.SDK) xsapiv1.SDK {
  75         var sdkRes xsapiv1.SDK
  76         assert.Nil(t, HTTPCli.Post("/sdks", sdkInstall, &sdkRes))
  77         assert.Equal(t, sdkRes.Status, "Installing")
  78         /*waiting for SDKStateChange event from channel*/
  79         sdkFromEvent := <-chSdks
  80         t.Log(sdkFromEvent)
  81         assert.Equal(t, sdkRes.ID, sdkFromEvent.ID)
  82         assert.Equal(t, "Installed", sdkFromEvent.Status)
  83         return sdkFromEvent
  84 }
  85
  86 func TestInstallFakeSdk(t *testing.T) {
  87         sdk := xsapiv1.SDKInstallArgs{
  88                 ID:       "",
  89                 Filename: sdkFileName,
  90                 Force:    false,
  91         }
  92
  93         chSdks := make(chan xsapiv1.SDK)
  94         defer close(chSdks)
  95         ConnectSDKStateChange(t, sCli, chSdks)
  96         installFakeSdk(t, sdk, chSdks)
  97         var sdkRes xsapiv1.SDK
  98         assert.NotNil(t, HTTPCli.Post("/sdks", sdk, &sdkRes))
  99         sdk.Force = true
 100         //installFakeSdk(t, sdk, chSdks)
 101 }
 102
 103 func TestSdksError(t *testing.T) {
 104         sdk := xsapiv1.SDKInstallArgs{
 105                 ID:       "",
 106                 Filename: "",
 107                 Force:    false,
 108         }
 109         var sdkRes xsapiv1.SDK
 110         assert.NotNil(t, HTTPCli.Post("/sdks", sdk, &sdkRes))
 111         sdk.ID = "42885c24-374e-3ef0-9723-0ce8a05191aa"
 112         assert.NotNil(t, HTTPCli.Post("/sdks", sdk, &sdkRes))
 113         sdk.Filename = "fake"
 114         assert.NotNil(t, HTTPCli.Post("/sdks", sdk, &sdkRes))
 115 }