Gitlink
/
forgeplus
Not watched
1
0
Fork 0
Code
Releases 16 Wiki evaluate Activity
Issues 0 Pull Requests 0 Datasets Model Cloudbrain HPC
You can not select more than 25 topics Topics must start with a chinese character,a letter or number, can include dashes ('-') and can be up to 35 characters long.
Tree: 07bc3b4eab
Branches Tags
${ item.name }
Create branch ${ searchTerm }
from '07bc3b4eab'
${ noResults }
forgeplus/app/controllers/api/v1/projects/pipelines_controller.rb

464 lines
19 kB
Raw Blame History 

  1. class Api::V1::Projects::PipelinesController < Api::V1::BaseController

  2.   before_action :require_operate_above

  3. 

  4.   def index

  5.     @pipelines = Action::Pipeline.where(project_id: @project.id).order(updated_at: :desc)

  6.     @pipelines = paginate @pipelines

  7.   end

  8. 

  9.   def create

  10.     size = Action::Pipeline.where(pipeline_name: params[:pipeline_name], project_id: @project.id).size

  11.     tip_exception("已经存在#{params[:pipeline_name]}流水线！") if size > 0

  12.     @pipeline = Action::Pipeline.new(pipeline_name: params[:pipeline_name], project_id: @project.id)

  13.     @pipeline.file_name = ".gitea/workflows/#{@pipeline.pipeline_name}.yml"

  14.     @pipeline.branch = params[:branch] || @project.default_branch

  15.     @pipeline.json = params[:pipeline_json].to_json

  16.     pipeline_yaml = build_pipeline_yaml(params[:pipeline_name], params[:pipeline_json])

  17.     tip_exception("流水线yaml内空不能为空") if pipeline_yaml.blank?

  18.     @pipeline.yaml = pipeline_yaml

  19.     @pipeline.save!

  20.     sha = get_pipeline_file_sha(@pipeline.file_name, @pipeline.branch)

  21.     tip_exception("#{@pipeline.file_name}已存在") if sha

  22.     interactor = Gitea::CreateFileInteractor.call(current_user.gitea_token, @owner.login, content_params("create"))

  23.     tip_exception(interactor.error) unless interactor.success?

  24.     render_ok({ id: @pipeline.id })

  25.   end

  26. 

  27.   def save_yaml

  28.     @pipeline = Action::Pipeline.new(pipeline_name: params[:pipeline_name], project_id: @project.id)

  29.     @pipeline.file_name = ".gitea/workflows/#{@pipeline.pipeline_name}.yml"

  30.     @pipeline.branch = params[:branch] || @project.default_branch

  31.     @pipeline.json = params[:pipeline_json].to_json

  32.     pipeline_yaml = build_pipeline_yaml(params[:pipeline_name], params[:pipeline_json])

  33.     tip_exception("流水线yaml内空不能为空") if pipeline_yaml.blank?

  34.     @pipeline.yaml = pipeline_yaml

  35.     Rails.logger.info "pipeline_yaml base64=========================#{Base64.encode64(@pipeline.yaml).gsub(/\n/, '')}"

  36.     sha = get_pipeline_file_sha(@pipeline.file_name, @pipeline.branch)

  37.     interactor = sha.present? ? Gitea::UpdateFileInteractor.call(current_user.gitea_token, @owner.login, content_params("update").merge(sha: sha)) : Gitea::CreateFileInteractor.call(current_user.gitea_token, @owner.login, content_params("create"))

  38.     tip_exception(interactor.error) unless interactor.success?

  39.     file = interactor.result

  40.     render_ok({ pipeline_yaml: pipeline_yaml, pipeline_name: params[:pipeline_name], file_name: @pipeline.file_name, sha: sha.present? ?  sha : file['content']['sha'] })

  41.   end

  42. 

  43.   def build_yaml

  44.     if params[:pipeline_json].present?

  45.       pipeline_yaml = build_pipeline_yaml(params[:pipeline_name], params[:pipeline_json])

  46.     else

  47.       pipeline_yaml = build_test_yaml

  48.     end

  49.     # render plain: pipeline_yaml

  50.     render_ok({ pipeline_yaml: pipeline_yaml })

  51.   end

  52. 

  53.   def update

  54.     @pipeline = Action::Pipeline.find(params[:id])

  55.     @pipeline.pipeline_name = params[:pipeline_name]

  56.     @pipeline.file_name = ".gitea/workflows/#{@pipeline.pipeline_name}.yml"

  57.     @pipeline.branch = params[:branch] || @project.default_branch

  58.     @pipeline.json = params[:pipeline_json].to_json

  59.     pipeline_yaml = build_pipeline_yaml(params[:pipeline_name], params[:pipeline_json])

  60.     tip_exception("流水线yaml内空不能为空") if pipeline_yaml.blank?

  61.     @pipeline.yaml = pipeline_yaml

  62.     @pipeline.save

  63.     sha = get_pipeline_file_sha(@pipeline.file_name, @pipeline.branch)

  64.     interactor = Gitea::UpdateFileInteractor.call(current_user.gitea_token, @owner.login, content_params("create").merge(sha: sha))

  65.     tip_exception(interactor.error) unless interactor.success?

  66.     file = interactor.result

  67.     render_ok({ pipeline_yaml: pipeline_yaml, pipeline_name: params[:pipeline_name], file_name: @pipeline.file_name, sha: file['content']['sha'] })

  68.   end

  69. 

  70.   def destroy

  71.     @pipeline = Action::Pipeline.find(params[:id])

  72.     if pipeline

  73.       interactor = Gitea::DeleteFileInteractor.call(current_user.gitea_token, @owner.login, content_params("update"))

  74.       tip_exception(interactor.error) unless interactor.success?

  75.       @pipeline.destroy!

  76.     end

  77.     render_ok

  78.   end

  79. 

  80.   def show

  81.     @pipeline = Action::Pipeline.find_by(id: params[:id])

  82.     @pipeline = Action::Pipeline.new(id: 0, pipeline_name: "test-ss", yaml: build_test_yaml) if @pipeline.blank?

  83.   end

  84. 

  85.   def build_pipeline_yaml(pipeline_name, pipeline_json)

  86.     if pipeline_json.present? && pipeline_json.present?

  87.       @pipeline_name = pipeline_name

  88.       params_nodes = pipeline_json["nodes"].select { |node| !["on-push", "on-schedule"].include?(node["name"]) }

  89.       on_nodes = pipeline_json["nodes"].select { |node| ["on-push", "on-schedule"].include?(node["name"]) }

  90.       @on_nodes = build_nodes(on_nodes)

  91.       @steps_nodes = build_nodes(params_nodes)

  92.       yaml = ERB.new(File.read(File.join(Rails.root, "app/views/api/v1/projects/pipelines", "build_pipeline.yaml.erb"))).result(binding)

  93.       # 删除空行内容

  94.       pipeline_yaml = yaml.gsub(/^\s*\n/, "")

  95.     else

  96.       pipeline_yaml = params[:pipeline_yaml]

  97.     end

  98.     Rails.logger.info "pipeline_yaml========================="

  99.     Rails.logger.info pipeline_yaml

  100.     pipeline_yaml

  101.   end

  102. 

  103.   def build_test_yaml

  104.     @pipeline_name = "I like it"

  105.     params_nodes = JSON.parse(demo.to_json)["nodes"].select { |node| !["on-push", "on-schedule"].include?(node["name"]) }

  106.     on_nodes = JSON.parse(demo.to_json)["nodes"].select { |node| ["on-push", "on-schedule"].include?(node["name"]) }

  107.     @on_nodes = build_nodes(on_nodes)

  108.     @steps_nodes = []

  109.     params_nodes.each do |input_node|

  110.       # Rails.logger.info "input_node=====0===#{input_node["name"]}======#{input_node["inputs"]}"

  111.       node = Action::Node.find_by(name: input_node["name"])

  112.       next if node.blank?

  113.       node.label = input_node["label"] if input_node["label"].present?

  114.       run_values = {}

  115.       input_values = {}

  116.       if input_node["inputs"].present?

  117.         Rails.logger.info "@inputs=====11===#{input_node["name"]}======#{input_node["inputs"]}"

  118.         input_node["inputs"].each do |input|

  119.           # Rails.logger.info "@inputs.input_name===#{input[:name]}"

  120.           # Rails.logger.info "@inputs.input_value===#{input["value"]}"

  121.           if input[:name].to_s.gsub("--", "") == "run"

  122.             run_values = run_values.merge({ "#{input[:name].gsub("--", "")}": "#{input["value"]}" })

  123.           else

  124.             input_values = input_values.merge({ "#{input[:name].gsub("--", "")}": "#{input["value"]}" })

  125.           end

  126.         end

  127.         node.run_values = run_values

  128.         node.input_values = input_values

  129.         # Rails.logger.info "@input_values run_values===#{node.run_values.to_json}"

  130.         # Rails.logger.info "@input_values input_values===#{node.input_values.to_json}"

  131.       end

  132.       @steps_nodes.push(node)

  133.     end

  134.     Rails.logger.info "@@on_nodes===#{@on_nodes.to_json}"

  135.     Rails.logger.info "@steps_nodes===#{@steps_nodes.to_json}"

  136.     yaml = ERB.new(File.read(File.join(Rails.root, "app/views/api/v1/projects/pipelines", "build_pipeline.yaml.erb"))).result(binding)

  137.     pipeline_yaml = yaml.gsub(/^\s*\n/, "")

  138.     Rails.logger.info "========================="

  139.     Rails.logger.info pipeline_yaml

  140.     pipeline_yaml

  141.   end

  142. 

  143.   private

  144. 

  145.   def get_pipeline_file_sha(file_name, branch)

  146.     file_path_uri = URI.parse(URI.encode(file_name))

  147.     interactor = Repositories::EntriesInteractor.call(@project.owner, @project.identifier, file_path_uri, ref: branch || @project.default_branch)

  148.     if interactor.success?

  149.       file = interactor.result

  150.       file['sha']

  151.     else

  152.       nil

  153.     end

  154.   end

  155. 

  156.   def content_params(opt)

  157.     {

  158.       filepath: ".gitea/workflows/#{@pipeline.pipeline_name}.yml",

  159.       branch: @pipeline.branch,

  160.       new_branch: @pipeline.branch,

  161.       content: opt == "create" ? Base64.encode64(@pipeline.yaml).gsub(/\n/, '') : @pipeline.yaml,

  162.       message: "#{opt} pipeline",

  163.       committer: {

  164.         email: current_user.mail,

  165.         name: current_user.login

  166.       },

  167.       identifier: @project.identifier

  168.     }

  169.   end

  170. 

  171.   def build_nodes(params_nodes)

  172.     steps_nodes = []

  173.     params_nodes.each do |input_node|

  174.       node = Action::Node.find_by(name: input_node["name"])

  175.       next if node.blank?

  176.       node.label = input_node["label"] if input_node["label"].present?

  177.       run_values = {}

  178.       input_values = {}

  179.       if input_node["inputs"].present?

  180.         Rails.logger.info "@inputs=====11===#{input_node["name"]}======#{input_node["inputs"]}"

  181.         input_node["inputs"].each do |input|

  182.           # Rails.logger.info "@inputs.input_name===#{input[:name]}"

  183.           # Rails.logger.info "@inputs.input_value===#{input["value"]}"

  184.           if input[:name].to_s.gsub("--", "") == "run"

  185.             run_values = run_values.merge({ "#{input[:name].gsub("--", "")}": "#{input["value"]}" })

  186.           else

  187.             input_values = input_values.merge({ "#{input[:name].gsub("--", "")}": "#{input["value"]}" })

  188.           end

  189.         end

  190.         node.run_values = run_values

  191.         node.input_values = input_values

  192.       end

  193.       steps_nodes.push(node)

  194.     end

  195.     steps_nodes

  196.   end

  197. 

  198.   def demo

  199.     {

  200.       "nodes": [{

  201.                   "id": "on-schedule-2fcf505",

  202.                   "name": "on-schedule",

  203.                   "full_name": "on-schedule",

  204.                   "description": " 定时器计划器",

  205.                   "icon": "https://testforgeplus.trustie.net/api/attachments/0445403c-5d9e-4495-8414-339f87981ca1",

  206.                   "action_node_types_id": 3,

  207.                   "yaml": "",

  208.                   "sort_no": 0,

  209.                   "use_count": 0,

  210.                   "inputs": [{

  211.                                "id": 8,

  212.                                "name": "cron",

  213.                                "input_type": "input",

  214.                                "description": "示例：\r\n- cron: '20 8 * * *'",

  215.                                "is_required": true,

  216.                                "value": "- corn: '0 10 * * *'"

  217.                              }],

  218.                   "x": 586,

  219.                   "y": 165.328125,

  220.                   "label": "on-schedule",

  221.                   "img": "https://testforgeplus.trustie.net/api/attachments/0445403c-5d9e-4495-8414-339f87981ca1",

  222.                   "isCluster": false,

  223.                   "type": "rect-node",

  224.                   "size": [110, 36],

  225.                   "labelCfg": {

  226.                     "style": {

  227.                       "fill": "transparent",

  228.                       "fontSize": 0,

  229.                       "boxShadow": "0px 0px 12px rgba(75, 84, 137, 0.05)",

  230.                       "overflow": "hidden",

  231.                       "x": -20,

  232.                       "y": 0,

  233.                       "textAlign": "left",

  234.                       "textBaseline": "middle"

  235.                     }

  236.                   },

  237.                   "style": {

  238.                     "active": {

  239.                       "fill": "rgb(247, 250, 255)",

  240.                       "stroke": "rgb(95, 149, 255)",

  241.                       "lineWidth": 2,

  242.                       "shadowColor": "rgb(95, 149, 255)",

  243.                       "shadowBlur": 10

  244.                     },

  245.                     "selected": {

  246.                       "fill": "rgb(255, 255, 255)",

  247.                       "stroke": "rgb(95, 149, 255)",

  248.                       "lineWidth": 4,

  249.                       "shadowColor": "rgb(95, 149, 255)",

  250.                       "shadowBlur": 10,

  251.                       "text-shape": {

  252.                         "fontWeight": 500

  253.                       }

  254.                     },

  255.                     "highlight": {

  256.                       "fill": "rgb(223, 234, 255)",

  257.                       "stroke": "#4572d9",

  258.                       "lineWidth": 2,

  259.                       "text-shape": {

  260.                         "fontWeight": 500

  261.                       }

  262.                     },

  263.                     "inactive": {

  264.                       "fill": "rgb(247, 250, 255)",

  265.                       "stroke": "rgb(191, 213, 255)",

  266.                       "lineWidth": 1

  267.                     },

  268.                     "disable": {

  269.                       "fill": "rgb(250, 250, 250)",

  270.                       "stroke": "rgb(224, 224, 224)",

  271.                       "lineWidth": 1

  272.                     },

  273.                     "nodeSelected": {

  274.                       "fill": "red",

  275.                       "shadowColor": "red",

  276.                       "stroke": "red",

  277.                       "text-shape": {

  278.                         "fill": "red",

  279.                         "stroke": "red"

  280.                       }

  281.                     },

  282.                     "fill": "#fff",

  283.                     "stroke": "transparent",

  284.                     "cursor": "pointer",

  285.                     "radius": 10,

  286.                     "overflow": "hidden",

  287.                     "lineWidth": 0.5,

  288.                     "shadowColor": "rgba(75,84,137,0.05)",

  289.                     "shadowBlur": 12

  290.                   },

  291.                   "cron": "- corn: '0 10 * * *'",

  292.                   "depth": 0

  293.                 }, {

  294.                   "id": "actions/setup-node@v3-257f29d",

  295.                   "name": "node",

  296.                   "full_name": "actions/setup-node@v3",

  297.                   "description": "",

  298.                   "icon": "https://testforgeplus.trustie.net/api/attachments/c4774fc1-ecd9-47fd-9878-1847bdaf98f6",

  299.                   "action_node_types_id": 1,

  300.                   "yaml": "",

  301.                   "sort_no": 0,

  302.                   "use_count": 0,

  303.                   "inputs": [{

  304.                                "id": 2,

  305.                                "name": "node-version",

  306.                                "input_type": "select",

  307.                                "is_required": false,

  308.                                "value": 55

  309.                              }],

  310.                   "x": 608,

  311.                   "y": 357.328125,

  312.                   "label": "node",

  313.                   "img": "https://testforgeplus.trustie.net/api/attachments/c4774fc1-ecd9-47fd-9878-1847bdaf98f6",

  314.                   "isCluster": false,

  315.                   "type": "rect-node",

  316.                   "size": [110, 36],

  317.                   "labelCfg": {

  318.                     "style": {

  319.                       "fill": "transparent",

  320.                       "fontSize": 0,

  321.                       "boxShadow": "0px 0px 12px rgba(75, 84, 137, 0.05)",

  322.                       "overflow": "hidden",

  323.                       "x": -20,

  324.                       "y": 0,

  325.                       "textAlign": "left",

  326.                       "textBaseline": "middle"

  327.                     }

  328.                   },

  329.                   "style": {

  330.                     "active": {

  331.                       "fill": "rgb(247, 250, 255)",

  332.                       "stroke": "rgb(95, 149, 255)",

  333.                       "lineWidth": 2,

  334.                       "shadowColor": "rgb(95, 149, 255)",

  335.                       "shadowBlur": 10

  336.                     },

  337.                     "selected": {

  338.                       "fill": "rgb(255, 255, 255)",

  339.                       "stroke": "rgb(95, 149, 255)",

  340.                       "lineWidth": 4,

  341.                       "shadowColor": "rgb(95, 149, 255)",

  342.                       "shadowBlur": 10,

  343.                       "text-shape": {

  344.                         "fontWeight": 500

  345.                       }

  346.                     },

  347.                     "highlight": {

  348.                       "fill": "rgb(223, 234, 255)",

  349.                       "stroke": "#4572d9",

  350.                       "lineWidth": 2,

  351.                       "text-shape": {

  352.                         "fontWeight": 500

  353.                       }

  354.                     },

  355.                     "inactive": {

  356.                       "fill": "rgb(247, 250, 255)",

  357.                       "stroke": "rgb(191, 213, 255)",

  358.                       "lineWidth": 1

  359.                     },

  360.                     "disable": {

  361.                       "fill": "rgb(250, 250, 250)",

  362.                       "stroke": "rgb(224, 224, 224)",

  363.                       "lineWidth": 1

  364.                     },

  365.                     "nodeSelected": {

  366.                       "fill": "red",

  367.                       "shadowColor": "red",

  368.                       "stroke": "red",

  369.                       "text-shape": {

  370.                         "fill": "red",

  371.                         "stroke": "red"

  372.                       }

  373.                     },

  374.                     "fill": "#fff",

  375.                     "stroke": "transparent",

  376.                     "cursor": "pointer",

  377.                     "radius": 10,

  378.                     "overflow": "hidden",

  379.                     "lineWidth": 0.5,

  380.                     "shadowColor": "rgba(75,84,137,0.05)",

  381.                     "shadowBlur": 12

  382.                   },

  383.                   "depth": 0,

  384.                   "node-version": 55

  385.                 }],

  386.       "edges": [{

  387.                   "source": "on-schedule-2fcf505",

  388.                   "target": "actions/setup-node@v3-257f29d",

  389.                   "style": {

  390.                     "active": {

  391.                       "stroke": "rgb(95, 149, 255)",

  392.                       "lineWidth": 1

  393.                     },

  394.                     "selected": {

  395.                       "stroke": "rgb(95, 149, 255)",

  396.                       "lineWidth": 2,

  397.                       "shadowColor": "rgb(95, 149, 255)",

  398.                       "shadowBlur": 10,

  399.                       "text-shape": {

  400.                         "fontWeight": 500

  401.                       }

  402.                     },

  403.                     "highlight": {

  404.                       "stroke": "rgb(95, 149, 255)",

  405.                       "lineWidth": 2,

  406.                       "text-shape": {

  407.                         "fontWeight": 500

  408.                       }

  409.                     },

  410.                     "inactive": {

  411.                       "stroke": "rgb(234, 234, 234)",

  412.                       "lineWidth": 1

  413.                     },

  414.                     "disable": {

  415.                       "stroke": "rgb(245, 245, 245)",

  416.                       "lineWidth": 1

  417.                     },

  418.                     "endArrow": {

  419.                       "path": "M 6,0 L 9,-1.5 L 9,1.5 Z",

  420.                       "d": 4.5,

  421.                       "fill": "#CDD0DC"

  422.                     },

  423.                     "cursor": "pointer",

  424.                     "lineWidth": 1,

  425.                     "opacity": 1,

  426.                     "stroke": "#CDD0DC",

  427.                     "radius": 1

  428.                   },

  429.                   "nodeStateStyle": {

  430.                     "hover": {

  431.                       "opacity": 1,

  432.                       "stroke": "#8fe8ff"

  433.                     }

  434.                   },

  435.                   "labelCfg": {

  436.                     "autoRotate": true,

  437.                     "style": {

  438.                       "fontSize": 10,

  439.                       "fill": "#FFF"

  440.                     }

  441.                   },

  442.                   "id": "edge-0.96904321945951241716516719464",

  443.                   "startPoint": {

  444.                     "x": 586,

  445.                     "y": 183.578125,

  446.                     "anchorIndex": 1

  447.                   },

  448.                   "endPoint": {

  449.                     "x": 608,

  450.                     "y": 339.078125,

  451.                     "anchorIndex": 0

  452.                   },

  453.                   "sourceAnchor": 1,

  454.                   "targetAnchor": 0,

  455.                   "type": "cubic-vertical",

  456.                   "curveOffset": [0, 0],

  457.                   "curvePosition": [0.5, 0.5],

  458.                   "minCurveOffset": [0, 0]

  459.                 }],

  460.       "combos": []

  461.     }

  462.   end

  463. end