Method OnInit

module/publish/iml.go:72–117

()

}

func (i *imlPublishModule) OnInit() {
	register.Handle(func(v server.Server) {
		ctx := context.Background()
		list, err := i.releaseService.GetRunningList(ctx)
		if err != nil {
			log.Errorf("onInit: get running list failed:%s", err.Error())
			return
		}
		if len(list) < 1 {
			return
		}

		serviceMap := make(map[string]*release.Release)
		serviceIds := make([]string, 0, len(list))
		for _, v := range list {
			if _, ok := serviceMap[v.Service]; !ok {
				serviceMap[v.Service] = v
				serviceIds = append(serviceIds, v.Service)
			}
		}
		overviewList, err := i.serviceOverviewService.List(ctx, serviceIds...)
		if err != nil {
			log.Errorf("onInit: get running list failed:%s", err.Error())
			return
		}
		for _, v := range overviewList {
			if v.IsReleased {
				return
			}
		}

		listCommits, err := i.apiDocService.ListLatestDocCommit(ctx, serviceIds...)
		if err != nil {
			log.Errorf("onInit: get running api doc commits failed:%s", err.Error())
			return
		}
		isReleased := true
		for _, v := range listCommits {
			i.serviceOverviewService.Update(ctx, v.Target, &service_overview.Update{
				ApiCount:        nil,
				ReleaseApiCount: &v.Data.APICount,
				IsReleased:      &isReleased,
			})
		}
	})
}

func (i *imlPublishModule) initGateway(ctx context.Context, partitionId string, clientDriver gateway.IClientDriver) error {
	return nil