Function checkJobAccess

api/handler/v2/job.go:2072–2092

(c echo.Context, jobId string)

}

func checkJobAccess(c echo.Context, jobId string) error {
	logger := handler.NewLogger().Named("checkJobAccess")
	logger.Info("start checkJobAccess")
	user, err := getCurrentUser(c)
	if err != nil {
		return fmt.Errorf("consul_addr=%v; connect to consul failed: %v", handler.ConsulAddr, err)
	}
	storeManager, err := common.NewStoreManager([]string{handler.ConsulAddr}, logger)
	if err != nil {
		return fmt.Errorf("consul_addr=%v; connect to consul failed: %v", handler.ConsulAddr, err)
	}
	job, err := storeManager.GetJobInfo(jobId)
	if nil != err {
		return fmt.Errorf("consul_addr=%v ; get job status list failed: %v", handler.ConsulAddr, err)
	}

	if !userHasAccess(storeManager, job.User, user) {
		return fmt.Errorf("current user %v:%v has not access to operate  job job_id=%v", user.Tenant, user.Username, jobId)
	}
	return nil
}

func checkUpdateJobInfo(c echo.Context, jobId string, create bool) error {
	logger := handler.NewLogger().Named("checkUpdateJobInfo")