devcloud/audit/apps/event/consumer/impl.go

@@ -58,6 +58,7 @@ func (i *consumer) Priority() int {
 	return event.PRIORITY - 1
 }
 
-func (i *consumer) Close(ctx context.Context) {
+func (i *consumer) Close(ctx context.Context) error {
 	i.ctx.Done()
+	return nil
 }

devcloud/cmdb/apps/resource/impl/impl.go

@@ -1,31 +1 @@
 package impl
-
-import (
-	"122.51.31.227/go-course/go18/devcloud/cmdb/apps/resource"
-	"github.com/infraboard/mcube/v2/ioc"
-	"github.com/infraboard/mcube/v2/ioc/config/datasource"
-)
-
-func init() {
-	ioc.Controller().Registry(&ResourceServiceImpl{})
-}
-
-var _ resource.Service = (*ResourceServiceImpl)(nil)
-
-type ResourceServiceImpl struct {
-	ioc.ObjectImpl
-}
-
-func (s *ResourceServiceImpl) Name() string {
-	return resource.APP_NAME
-}
-
-func (s *ResourceServiceImpl) Init() error {
-	if datasource.Get().AutoMigrate {
-		err := datasource.DB().AutoMigrate(&resource.Resource{})
-		if err != nil {
-			return err
-		}
-	}
-	return nil
-}

devcloud/cmdb/apps/resource/impl/resource.go

@@ -1,28 +1 @@
 package impl
-
-import (
-	"context"
-
-	"122.51.31.227/go-course/go18/devcloud/cmdb/apps/resource"
-	"github.com/infraboard/mcube/v2/ioc/config/datasource"
-	"github.com/infraboard/mcube/v2/types"
-)
-
-// Add implements resource.Service.
-func (s *ResourceServiceImpl) Add(ctx context.Context, in *resource.Resource) (*resource.Resource, error) {
-	if err := datasource.DBFromCtx(ctx).Save(in).Error; err != nil {
-		return nil, err
-	}
-
-	return in, nil
-}
-
-// DeleteResource implements resource.Service.
-func (s *ResourceServiceImpl) DeleteResource(ctx context.Context, in *resource.DeleteResourceRequest) error {
-	panic("unimplemented")
-}
-
-// Search implements resource.Service.
-func (s *ResourceServiceImpl) Search(ctx context.Context, in *resource.SearchRequest) (*types.Set[*resource.Resource], error) {
-	panic("unimplemented")
-}

devcloud/cmdb/apps/secret/impl/secret.go

@@ -91,10 +91,8 @@ func (s *SecretServiceImpl) SyncResource(ctx context.Context, in *secret.SyncRes
 	// 获取syncer,  执行同步
 	for _, rs := range ins.ResourceType {
 		syncer := secret.GetSyncer(rs)
-		for _, region := range ins.Regions {
+		taskInfo := syncer.Sync(ctx, ins, rs)
-			taskInfo := syncer.Sync(ctx, ins, region, rs)
+		taskSet.Add(taskInfo)
-			taskSet.Add(taskInfo)
-		}
 	}
 	return taskSet, nil
 }

devcloud/cmdb/apps/secret/impl/secret_test.go

@@ -1,7 +1,6 @@
 package impl_test
 
 import (
-	"os"
 	"testing"
 	"time"
 
@@ -13,8 +12,8 @@ func TestCreateSecret(t *testing.T) {
 	req := secret.NewCreateSecretRequest()
 	req.Name = "腾讯云只读账号"
 	req.Vendor = resource.VENDOR_TENCENT
-	req.ApiKey = os.Getenv("TX_API_KEY")
+	req.ApiKey = "xxx"
-	req.ApiSecret = os.Getenv("TX_API_SECRET")
+	req.ApiSecret = "xx"
 	req.SetEnabled(true)
 	req.ResourceType = append(req.ResourceType, resource.TYPE_VM)
 	req.Regions = []string{"ap-shanghai", "ap-guangzhou"}
@@ -35,7 +34,7 @@ func TestQuerySecret(t *testing.T) {
 }
 
 const (
-	SECRET_ID = "e5aa1ad4-6069-397e-a7ed-a78b9cd2a93b"
+	SECRET_ID = "ed02f7cd-ee5b-33f0-bdf5-e305ecb3efb4"
 )
 
 func TestDescribeSecret(t *testing.T) {

devcloud/cmdb/apps/secret/sync.go

@@ -30,5 +30,5 @@ func RegistrySyncer(t resource.TYPE, s Syncer) {
 
 type Syncer interface {
 	// 资源同步
-	Sync(ctx context.Context, ins *Secret, region string, rt resource.TYPE) *task.Task
+	Sync(context.Context, *Secret, resource.TYPE) *task.Task
 }

devcloud/cmdb/apps/secret/sync/data/vm.json

@@ -1,59 +0,0 @@
-{
-  "Response": {
-    "InstanceSet": [
-      {
-        "BlueprintId": "lhbp-b46k6f98",
-        "BundleId": "bundle_starter_mc_promo_med2_02",
-        "CPU": 2,
-        "CreatedTime": "2025-03-02T09:54:10Z",
-        "ExpiredTime": "2026-03-02T09:54:10Z",
-        "InitInvocationId": "",
-        "InstanceChargeType": "PREPAID",
-        "InstanceId": "lhins-dxvcse1s",
-        "InstanceName": "Docker CE-MyRb",
-        "InstanceRestrictState": "NORMAL",
-        "InstanceState": "RUNNING",
-        "InternetAccessible": {
-          "InternetChargeType": "TRAFFIC_POSTPAID_BY_HOUR",
-          "InternetMaxBandwidthOut": 4,
-          "PublicIpAssigned": true
-        },
-        "IsolatedTime": null,
-        "LatestOperation": "",
-        "LatestOperationRequestId": "",
-        "LatestOperationStartedTime": "2025-03-02T09:53:37Z",
-        "LatestOperationState": "",
-        "LoginSettings": {
-          "KeyIds": []
-        },
-        "Memory": 2,
-        "OsName": "Ubuntu Server 24.04 LTS 64bit",
-        "Platform": "UBUNTU",
-        "PlatformType": "LINUX_UNIX",
-        "PrivateAddresses": [
-          "10.0.4.9"
-        ],
-        "PublicAddresses": [
-          "122.51.31.227"
-        ],
-        "PublicIpv6Addresses": [],
-        "RenewFlag": "NOTIFY_AND_MANUAL_RENEW",
-        "SupportIpv6Detail": {
-          "Detail": "EFFECTIVE_IMMEDIATELY",
-          "IsSupport": true,
-          "Message": ""
-        },
-        "SystemDisk": {
-          "DiskId": "lhdisk-adyw1bgo",
-          "DiskSize": 50,
-          "DiskType": "CLOUD_SSD"
-        },
-        "Tags": [],
-        "Uuid": "dd452294-6c06-4d4e-ab5f-b5d74404b863",
-        "Zone": "ap-shanghai-2"
-      }
-    ],
-    "RequestId": "9863afd3-47f4-4aa0-9e95-9b61ea3e5573",
-    "TotalCount": 1
-  }
-}

devcloud/cmdb/apps/secret/sync/vm.go

@@ -2,20 +2,14 @@ package sync
 
 import (
 	"context"
-	"fmt"
+	"time"
 
 	"122.51.31.227/go-course/go18/devcloud/cmdb/apps/resource"
 	"122.51.31.227/go-course/go18/devcloud/cmdb/apps/secret"
 	"github.com/infraboard/mcube/v2/ioc"
 	"github.com/infraboard/mcube/v2/ioc/config/log"
-	"github.com/infraboard/mcube/v2/tools/ptr"
-	"github.com/infraboard/modules/task/apps/event"
 	"github.com/infraboard/modules/task/apps/task"
 	"github.com/rs/zerolog"
-
-	"github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/common"
-	"github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/common/profile"
-	lighthouse "github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/lighthouse/v20200324"
 )
 
 func init() {
@@ -41,76 +35,13 @@ func (s *VmSyncerServiceImpl) Init() error {
 }
 
 // Sync implements secret.Syncer.
-func (s *VmSyncerServiceImpl) Sync(ctx context.Context, ins *secret.Secret, region string, rs resource.TYPE) *task.Task {
+func (s *VmSyncerServiceImpl) Sync(ctx context.Context, secretIns *secret.Secret, rs resource.TYPE) *task.Task {
-	// 怎么使用对应secret 来完成, 用的腾讯的API
-	// https://console.cloud.tencent.com/api/explorer?Product=cvm&Version=2017-03-12&Action=DescribeRegions
-	// https://console.cloud.tencent.com/api/explorer?Product=lighthouse&Version=2020-03-24&Action=DescribeInstances
 	return task.GetService().Run(ctx, task.NewFnTask(func(ctx context.Context, req any) error {
-		taskInfo := task.GetTaskFromCtx(ctx)
-		_, err := event.GetService().AddEvent(ctx, task.NewInfoEvent("同步开始", taskInfo.Id))
-		if err != nil {
-			return err
-		}
-		defer event.GetService().AddEvent(ctx, task.NewInfoEvent("同步结束", taskInfo.Id))
 
-		// 实例化一个认证对象，入参需要传入腾讯云账户 SecretId 和 SecretKey，此处还需注意密钥对的保密
+		// taskInfo := task.GetTaskFromCtx(ctx)
-		// 代码泄露可能会导致 SecretId 和 SecretKey 泄露，并威胁账号下所有资源的安全性
+		s.log.Debug().Msg("test for vm sync wait")
-		// 以下代码示例仅供参考，建议采用更安全的方式来使用密钥
+		time.Sleep(1 * time.Second)
-		// 请参见：https://cloud.tencent.com/document/product/1278/85305
+		// secrt同步
-		// 密钥可前往官网控制台 https://console.cloud.tencent.com/cam/capi 进行获取
-		credential := common.NewCredential(
-			ins.ApiKey,
-			ins.ApiSecret,
-		)
-		// 使用临时密钥示例
-		// credential := common.NewTokenCredential("SecretId", "SecretKey", "Token")
-		// 实例化一个client选项，可选的，没有特殊需求可以跳过
-		cpf := profile.NewClientProfile()
-		cpf.HttpProfile.Endpoint = "lighthouse.tencentcloudapi.com"
-		// 实例化要请求产品的client对象,clientProfile是可选的
-		// "ap-shanghai"
-		client, _ := lighthouse.NewClient(credential, region, cpf)
-
-		// 实例化一个请求对象,每个接口都会对应一个request对象
-		request := lighthouse.NewDescribeInstancesRequest()
-
-		// 返回的resp是一个DescribeInstancesResponse的实例，与请求对象对应
-		response, err := client.DescribeInstances(request)
-		if err != nil {
-			return err
-		}
-
-		_, err = event.GetService().AddEvent(ctx, task.NewInfoEvent("接口调用成功", taskInfo.Id).SetDetail(response.ToJsonString()))
-		if err != nil {
-			return err
-		}
-
-		// 获取出了实例的列表
-		for _, vm := range response.Response.InstanceSet {
-			// 转化为一个Resource对象
-			res := resource.NewResource()
-			res.Vendor = resource.VENDOR_TENCENT
-			res.CredentialId = ins.Id
-			res.Region = region
-			res.ResourceType = resource.TYPE_VM
-			res.Id = ptr.GetValue(vm.InstanceId)
-			res.Name = ptr.GetValue(vm.InstanceName)
-			res.Cpu = ptr.GetValue(vm.CPU)
-			res.Memory = ptr.GetValue(vm.Memory)
-			res.SystemStorage = ptr.GetValue(vm.SystemDisk.DiskSize)
-			res.Extra["os_name"] = ptr.GetValue(vm.OsName)
-			res.PrivateAddress = ptr.GetArrayValue(vm.PrivateAddresses)
-			res.PublicAddress = ptr.GetArrayValue(vm.PublicAddresses)
-			res.Phase = ptr.GetValue(vm.InstanceState)
-			res, err := resource.GetService().Add(ctx, res)
-			if err != nil {
-				return err
-			}
-			_, err = event.GetService().AddEvent(ctx, task.NewInfoEvent(fmt.Sprintf("资源%s同步成功", res.Name), taskInfo.Id).SetDetail(res.String()))
-			if err != nil {
-				return err
-			}
-		}
 		return nil
-	}, ins).SetAsync(true).SetLabel(secret.TASK_LABLE_SECRET_ID, ins.Id))
+	}, secretIns).SetAsync(true).SetLabel(secret.TASK_LABLE_SECRET_ID, secretIns.Id))
 }

devcloud/etc/application.toml

@@ -11,7 +11,7 @@
   database = "devcloud_go18"
   username = "root"
   password = "123456"
-  auto_migrate = true
+  auto_migrate = false
   debug = false
 
 [mongo]

devcloud/etc/unit_test.env

@@ -1,3 +0,0 @@
-
-TX_API_KEY=
-TX_API_SECRET=

go.mod

@@ -9,14 +9,12 @@ require (
 	github.com/gin-gonic/gin v1.10.0
 	github.com/google/uuid v1.6.0
 	github.com/infraboard/devops v0.0.6
-	github.com/infraboard/mcube/v2 v2.0.63
+	github.com/infraboard/mcube/v2 v2.0.61
-	github.com/infraboard/modules v0.0.20
+	github.com/infraboard/modules v0.0.13
 	github.com/rs/xid v1.6.0
 	github.com/rs/zerolog v1.34.0
 	github.com/segmentio/kafka-go v0.4.47
 	github.com/stretchr/testify v1.10.0
-	github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/common v1.0.1138
-	github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/lighthouse v1.0.1134
 	go.mongodb.org/mongo-driver v1.17.3
 	golang.org/x/crypto v0.38.0
 	gopkg.in/yaml.v3 v3.0.1
@@ -82,7 +80,6 @@ require (
 	github.com/prometheus/common v0.63.0 // indirect
 	github.com/prometheus/procfs v0.16.0 // indirect
 	github.com/remyoudompheng/bigfft v0.0.0-20230129092748-24d4a6f8daec // indirect
-	github.com/robfig/cron/v3 v3.0.1 // indirect
 	github.com/spf13/cobra v1.9.1 // indirect
 	github.com/spf13/pflag v1.0.6 // indirect
 	github.com/twitchyliquid64/golang-asm v0.15.1 // indirect

go.sum

@@ -97,10 +97,10 @@ github.com/inconshreveable/mousetrap v1.1.0 h1:wN+x4NVGpMsO7ErUn/mUI3vEoE6Jt13X2
 github.com/inconshreveable/mousetrap v1.1.0/go.mod h1:vpF70FUmC8bwa3OWnCshd2FqLfsEA9PFc4w1p2J65bw=
 github.com/infraboard/devops v0.0.6 h1:oo7RfRBxu9hbI/+bYzXuX40BfG1hRyVtxC0fBhoFGBU=
 github.com/infraboard/devops v0.0.6/go.mod h1:Ac+W3wFy5pG9EH7f1W8DxiAZRhnTDFHrp27WKkYnNoU=
-github.com/infraboard/mcube/v2 v2.0.63 h1:OUmDajfLAQ1LUVEutCSRbDIQItyLSPHYWXUJLO6IbaE=
+github.com/infraboard/mcube/v2 v2.0.61 h1:al8Z+poXXOjfTIAY48ujFzV1uYzH/N7/xmve/ZXArbo=
-github.com/infraboard/mcube/v2 v2.0.63/go.mod h1:TbYs8cnD8Cg19sTdU0D+vqWAN+LzoxhMYWmAC2pfJkQ=
+github.com/infraboard/mcube/v2 v2.0.61/go.mod h1:TbYs8cnD8Cg19sTdU0D+vqWAN+LzoxhMYWmAC2pfJkQ=
-github.com/infraboard/modules v0.0.20 h1:5tNT9eSkTBCx4OA+7sZr1Bf+miOGf9Zft2X/sESrlpE=
+github.com/infraboard/modules v0.0.13 h1:wykjQswgVnqv3mL2qtjqAui/AWuZWPaG/dkzITmDkrc=
-github.com/infraboard/modules v0.0.20/go.mod h1:H2kRn3Ksp+3OMt9yYB2imNR2RJgSytTVt9WFP8XpDRQ=
+github.com/infraboard/modules v0.0.13/go.mod h1:B+wkbV8oGOmSwribb3y/+F9PAp8H8UzhkrK7YySuYIk=
 github.com/jackc/pgpassfile v1.0.0 h1:/6Hmqy13Ss2zCq62VdNG8tM1wchn8zjSGOBJ6icpsIM=
 github.com/jackc/pgpassfile v1.0.0/go.mod h1:CEx0iS5ambNFdcRtxPj5JhEz+xB6uRky5eyVu/W2HEg=
 github.com/jackc/pgservicefile v0.0.0-20231201235250-de7065d80cb9 h1:L0QtFUgDarD7Fpv9jeVMgy/+Ec0mtnmYuImjTz6dtDA=
@@ -181,8 +181,6 @@ github.com/prometheus/procfs v0.16.0/go.mod h1:8veyXUu3nGP7oaCxhX6yeaM5u4stL2FeM
 github.com/remyoudompheng/bigfft v0.0.0-20200410134404-eec4a21b6bb0/go.mod h1:qqbHyh8v60DhA7CoWK5oRCqLrMHRGoxYCSS9EjAz6Eo=
 github.com/remyoudompheng/bigfft v0.0.0-20230129092748-24d4a6f8daec h1:W09IVJc94icq4NjY3clb7Lk8O1qJ8BdBEF8z0ibU0rE=
 github.com/remyoudompheng/bigfft v0.0.0-20230129092748-24d4a6f8daec/go.mod h1:qqbHyh8v60DhA7CoWK5oRCqLrMHRGoxYCSS9EjAz6Eo=
-github.com/robfig/cron/v3 v3.0.1 h1:WdRxkvbJztn8LMz/QEvLN5sBU+xKpSqwwUO1Pjr4qDs=
-github.com/robfig/cron/v3 v3.0.1/go.mod h1:eQICP3HwyT7UooqI/z+Ov+PtYAWygg1TEWWzGIFLtro=
 github.com/rogpeppe/go-internal v1.13.1 h1:KvO1DLK/DRN07sQ1LQKScxyZJuNnedQ5/wKSR38lUII=
 github.com/rogpeppe/go-internal v1.13.1/go.mod h1:uMEvuHeurkdAXX61udpOXGD/AzZDWNMNyH2VO9fmH0o=
 github.com/rs/xid v1.6.0 h1:fV591PaemRlL6JfRxGDEPl69wICngIQ3shQtzfy2gxU=
@@ -209,11 +207,6 @@ github.com/stretchr/testify v1.8.1/go.mod h1:w2LPCIKwWwSfY2zedu0+kehJoqGctiVI29o
 github.com/stretchr/testify v1.8.4/go.mod h1:sz/lmYIOXD/1dqDmKjjqLyZ2RngseejIcXlSw2iwfAo=
 github.com/stretchr/testify v1.10.0 h1:Xv5erBjTwe/5IxqUQTdXv5kgmIvbHo3QQyRwhJsOfJA=
 github.com/stretchr/testify v1.10.0/go.mod h1:r2ic/lqez/lEtzL7wO/rwa5dbSLXVDPFyf8C91i36aY=
-github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/common v1.0.1134/go.mod h1:r5r4xbfxSaeR04b166HGsBa/R4U3SueirEUpXGuw+Q0=
-github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/common v1.0.1138 h1:eMVp9kzjBptP3K0xaUUS68dF5nNTFLbom3uQREaqftM=
-github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/common v1.0.1138/go.mod h1:r5r4xbfxSaeR04b166HGsBa/R4U3SueirEUpXGuw+Q0=
-github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/lighthouse v1.0.1134 h1:+pjecViStkJrHVbZs+OtCFULfAoD0UOxAZJVDwBjKC8=
-github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/lighthouse v1.0.1134/go.mod h1:vp2EZhERa7VxNFUlntLv7JDu3OD/pbpUpduFf5BGSfQ=
 github.com/twitchyliquid64/golang-asm v0.15.1 h1:SU5vSMR7hnwNxj24w34ZyCi/FmDZTkS4MhqMhdFk5YI=
 github.com/twitchyliquid64/golang-asm v0.15.1/go.mod h1:a1lVb/DtPvCB8fslRZhAngC2+aY1QWCk3Cedj/Gdt08=
 github.com/ugorji/go/codec v1.2.12 h1:9LC83zGrHhuUA9l16C9AHXAqEV/2wBQ4nkvumAE65EE=

skills/html/README.md

@@ -1,3 +0,0 @@
-# HTML
-
-vscode 插件: open in browser

skills/html/index.css

@@ -1,39 +0,0 @@
-/* p {
-  color: blue;
-} */
-
-/* . class */
-.red {
-  color: red;
-}
-
-/* # 表示这是一个id选择器 */
-#input01 {
-    width: 400px;
-}
-
-/* ul>li:first-child {
-  font-weight: 600;
-} */
-
-
-ul li:hover {
-  color: red;  
-  font-size: 20px;
-  font-weight: 600;
-}
-
-img {
-  width: 220px;
-  height: 220px;
-  object-fit: cover;  /* 裁剪成正方形 */
-  border-radius: 4px; /* 可选：圆角 */
-  margin: 10px;
-}
-
-.img-warppter {
-    height: 300px;
-    display: flex;
-    justify-content: space-between;
-    align-items: center;
-}

skills/html/index.html

@@ -1,109 +0,0 @@
-<html lang="en">
-  <head>
-    <meta charset="UTF-8" />
-    <meta name="viewport" content="width=device-width, initial-scale=1.0" />
-    <title>Document</title>
-    <link rel="stylesheet" type="text/css" href="./index.css" />
-    <!-- <style>
-        p {
-            color: blue;
-        }
-    </style> -->
-  </head>
-  <body>
-    <h1 id="title01">HTML 语法介绍</h1>
-    <p class="red">段落</p>
-    <p>段落</p>
-    <span class="red">文字A</span>
-    <br />
-    <span class="red">文字B</span>
-    <br />
-    <form action="demo_form.php" method="get">
-      First name: <input id="input01" type="text" name="fname" /><br />
-      Last name: <input type="text" name="lname" /><br />
-      <input type="submit" value="提交" />
-    </form>
-
-    <iframe
-      src="https://www.baidu.com"
-      style="width: 800px; height: 400"
-    ></iframe>
-
-    <table border="1">
-      <tr>
-        <th>Month</th>
-        <th>Savings</th>
-      </tr>
-      <tr>
-        <td>January</td>
-        <td>$100</td>
-      </tr>
-      <tr>
-        <td>February</td>
-        <td>$80</td>
-      </tr>
-    </table>
-
-    <div style="width: 400px; height: 400; background-color: aqua">
-      <table border="1">
-        <tr>
-          <th>Month</th>
-          <th>Savings</th>
-        </tr>
-        <tr>
-          <td>January</td>
-          <td>$100</td>
-        </tr>
-        <tr>
-          <td>February</td>
-          <td>$80</td>
-        </tr>
-      </table>
-      <br />
-      <p>这是一个段落</p>
-    </div>
-    <hr />
-    <div style="width: 400px; height: 400; background-color: aqua">
-      <table border="1">
-        <tr>
-          <th>Month</th>
-          <th>Savings</th>
-        </tr>
-        <tr>
-          <td>January</td>
-          <td>$100</td>
-        </tr>
-        <tr>
-          <td>February</td>
-          <td>$80</td>
-        </tr>
-      </table>
-      <br />
-      <p>这是一个段落</p>
-    </div>
-
-    <span>span1</span>
-    <span>span2</span>
-
-    <br />
-    <ul id="list_menu" class="ul_class">
-      <li id="coffee">Coffee</li>
-      <li>Tea</li>
-      <li>Milk</li>
-      <div>
-        <li>绿茶</li>
-        <li>红茶</li>
-      </div>
-    </ul>
-
-    <div class="img-warppter">
-      <img src="./images/1.jpeg"  alt="" />
-      <img src="./images/2.jpeg" alt="" />
-      <img src="./images/1.jpeg" alt="" />
-    </div>
-
-    <script>
-      document.getElementById("title01").style.color = "red";
-    </script>
-  </body>
-</html>

skills/javascript/README.md

@@ -1,5 +0,0 @@
-# js
-
-[课件](https://gitee.com/infraboard/go-course/blob/master/day19/javascript.md)
-
-安装Code Runner插件

skills/javascript/app.mjs

@@ -1,16 +0,0 @@
-// 唯一的全局变量MYAPP:
-var MYAPP = {};
-
-// 其他变量:
-MYAPP.name = 'myapp';
-MYAPP.version = 1.0;
-
-// 其他函数:
-MYAPP.foo = function () {
-    return 'foo';
-};
-
-// export {MYAPP}
-
-// MYAPP --> default
-export default MYAPP

skills/javascript/async.drawio

@@ -1,57 +0,0 @@
-<mxfile host="65bd71144e">
-    <diagram id="0WS3t2Fnvb50-m555Ywn" name="第 1 页">
-        <mxGraphModel dx="1176" dy="389" grid="1" gridSize="10" guides="1" tooltips="1" connect="1" arrows="1" fold="1" page="1" pageScale="1" pageWidth="827" pageHeight="1169" math="0" shadow="0">
-            <root>
-                <mxCell id="0"/>
-                <mxCell id="1" parent="0"/>
-                <mxCell id="2" value="事件触发器" style="rounded=0;whiteSpace=wrap;html=1;" vertex="1" parent="1">
-                    <mxGeometry x="180" y="70" width="40" height="410" as="geometry"/>
-                </mxCell>
-                <mxCell id="3" value="fna" style="rounded=0;whiteSpace=wrap;html=1;" vertex="1" parent="1">
-                    <mxGeometry x="240" y="90" width="120" height="50" as="geometry"/>
-                </mxCell>
-                <mxCell id="4" value="fnb" style="rounded=0;whiteSpace=wrap;html=1;" vertex="1" parent="1">
-                    <mxGeometry x="360" y="120" width="120" height="50" as="geometry"/>
-                </mxCell>
-                <mxCell id="5" value="fnc" style="rounded=0;whiteSpace=wrap;html=1;" vertex="1" parent="1">
-                    <mxGeometry x="480" y="140" width="120" height="50" as="geometry"/>
-                </mxCell>
-                <mxCell id="6" value="fnd" style="rounded=0;whiteSpace=wrap;html=1;" vertex="1" parent="1">
-                    <mxGeometry x="600" y="160" width="120" height="50" as="geometry"/>
-                </mxCell>
-                <mxCell id="7" value="async fna" style="rounded=0;whiteSpace=wrap;html=1;" vertex="1" parent="1">
-                    <mxGeometry x="280" y="270" width="120" height="50" as="geometry"/>
-                </mxCell>
-                <mxCell id="8" value="async fnb" style="rounded=0;whiteSpace=wrap;html=1;" vertex="1" parent="1">
-                    <mxGeometry x="280" y="350" width="120" height="50" as="geometry"/>
-                </mxCell>
-                <mxCell id="9" value="async fnc" style="rounded=0;whiteSpace=wrap;html=1;" vertex="1" parent="1">
-                    <mxGeometry x="280" y="430" width="120" height="50" as="geometry"/>
-                </mxCell>
-                <mxCell id="10" value="async fnd" style="rounded=0;whiteSpace=wrap;html=1;" vertex="1" parent="1">
-                    <mxGeometry x="280" y="510" width="120" height="50" as="geometry"/>
-                </mxCell>
-                <mxCell id="13" style="edgeStyle=none;html=1;exitX=0;exitY=0.5;exitDx=0;exitDy=0;entryX=1;entryY=1;entryDx=0;entryDy=0;" edge="1" parent="1" source="11" target="7">
-                    <mxGeometry relative="1" as="geometry"/>
-                </mxCell>
-                <mxCell id="16" value="await" style="edgeLabel;html=1;align=center;verticalAlign=middle;resizable=0;points=[];" vertex="1" connectable="0" parent="13">
-                    <mxGeometry x="0.3011" y="1" relative="1" as="geometry">
-                        <mxPoint as="offset"/>
-                    </mxGeometry>
-                </mxCell>
-                <mxCell id="15" style="edgeStyle=none;html=1;exitX=0;exitY=0.75;exitDx=0;exitDy=0;entryX=1;entryY=1;entryDx=0;entryDy=0;" edge="1" parent="1" source="11" target="8">
-                    <mxGeometry relative="1" as="geometry"/>
-                </mxCell>
-                <mxCell id="11" value="excutor(&lt;div&gt;aysnc executor&lt;/div&gt;&lt;div&gt;&lt;br&gt;&lt;/div&gt;&lt;div&gt;event pool)&lt;/div&gt;" style="rounded=0;whiteSpace=wrap;html=1;" vertex="1" parent="1">
-                    <mxGeometry x="591" y="270" width="120" height="290" as="geometry"/>
-                </mxCell>
-                <mxCell id="12" style="edgeStyle=none;html=1;exitX=1;exitY=0.5;exitDx=0;exitDy=0;entryX=0.017;entryY=0.31;entryDx=0;entryDy=0;entryPerimeter=0;" edge="1" parent="1" source="7" target="11">
-                    <mxGeometry relative="1" as="geometry"/>
-                </mxCell>
-                <mxCell id="14" style="edgeStyle=none;html=1;exitX=1;exitY=0.5;exitDx=0;exitDy=0;entryX=-0.025;entryY=0.652;entryDx=0;entryDy=0;entryPerimeter=0;" edge="1" parent="1" source="8" target="11">
-                    <mxGeometry relative="1" as="geometry"/>
-                </mxCell>
-            </root>
-        </mxGraphModel>
-    </diagram>
-</mxfile>

skills/javascript/promise.js

@@ -1,69 +0,0 @@
-function testApiCall(success, failed) {
-    var timeOut = Math.random() * 2;
-    console.log('set timeout to: ' + timeOut + ' seconds.');
-    setTimeout(function () {
-        if (timeOut < 1) {
-            console.log('call resolve()...');
-            success('200 OK');
-        }
-        else {
-            console.log('call reject()...');
-            failed('timeout in ' + timeOut + ' seconds.');
-        }
-    }, timeOut * 1000);
-}
-
-// 通过回调实现的异步方案
-// fna()
-// fnb()
-// fnc()
-console.log('start ...')
-testApiCall(
-    // success callback
-    (data) => {
-        console.log(data)
-    },
-    // failed callback
-    (error) => {
-        console.log(error)
-    }
-)
-console.log('end ...')
-
-// fna(fnb_sucess(fnc_success(fnd_success)), fnb_error(fnc_error(fnd_error)))
-
-// promise 封装技术, 他让异步成为一种标准, 使用promise的标准方式来处理异常
-// promise 像一个接口，他约束了 excutor对象的 实现方式
-var p1 = new Promise(testApiCall)
-// p1.then((data) => {
-//     console.log(data)
-//     //  p2.then().catch().finally()
-// }).catch((error) => {
-//     console.log(error)
-// }).finally(() => {
-//     console.log('finnal')
-// })
-
-
-// 异步等待
-// 以同步编程的方式，来实现异步代码
-var async_await = async () => {
-    try {
-        const resp = await p1
-        console.log(resp)
-
-        // const res2 = await p2
-        // console.log(resp2)
-
-        // const res3 = await p3
-        // console.log(resp2)
-    } catch (error) {
-        console.log(error)
-    }
-}
-
-async_await()
-
-
-
-

skills/javascript/test.js

@@ -1,84 +0,0 @@
-// function sum (x , y) {
-//     return x + y
-// }
-
-// console.log(sum(1, 10)) 
-
-// var person = {name: '小明', age: 23}
-
-// console.log(person)
-
-// person.greet = function() {
-//     console.log(`hello, my name is ${this.name}, age ${this.age}`)
-// }
-// person.greet()
-
-
-// var name = '李四'
-// var age = 23
-
-// function greet () {
-//     console.log(`hello, my name is ${name}, age ${age}`)
-// }
-
-// greet()
-
-
-// fn = function (x , y) {
-//     return x + y
-// }
-// console.log(fn(1,2)) 
-
-
-// fn = (x, y) => {
-//     return x + y
-// }
-// console.log(fn(1,2)) 
-
-// fn = (x, y) => { return x + y}
-// console.log(fn(1,2)) 
-
-// fn = (x, y) => x + y
-// console.log(fn(1,2)) 
-
-// pow = x => x * x
-
-// console.log(pow(100))
-
-// pkg
-import {firstName, sum as my_sum} from './tool.mjs'
-console.log(my_sum(1,10)) 
-console.log(firstName)
-
-// pkg.
-// import { MYAPP } from './app.mjs'
-// console.log(MYAPP.version)
-
-
-
-// pkg 
-// import { default as MYAPP } from './app.mjs'
-import appPKg from './app.mjs'
-console.log(appPKg.name) 
-
-// for item := rang a {}
-var a = ['A', 'B', 'C'];
-for (var item of a) {
-    // fn(item)
-    console.log(item)
-}
-
-// for k,v := range o {}
-var o = {
-    name: 'Jack',
-    age: 20,
-    city: 'Beijing'
-};
-for (var item of Object.keys(o)) {
-    console.log(item, o[item])
-}
-
-// forEach
-a.forEach((item) => {
-    console.log(item)
-})

skills/javascript/tool.mjs

@@ -1,10 +0,0 @@
-// export var sum = (x, y) => {return x + y}
-export function sum(x, y) {
-    return x + y
-}
-
-var firstName = 'Michael';
-var lastName = 'Jackson';
-var year = 1958;
-
-export {firstName, lastName, year}

skills/kafka/kafka_test.go

@@ -116,7 +116,7 @@ func TestReadMessage(t *testing.T) {
 		GroupID: "devcloud-go18-audit",
 		// 可以指定Partition消费消息
 		// Partition: 0,
-		Topic:    "task_run_events",
+		Topic:    "audit_go18",
 		MinBytes: 10e3, // 10KB
 		MaxBytes: 10e6, // 10MB
 	})