java通过代码实现创建项目,提交项目等功能

ps:首先要讲一下前提。用的是gitlab。然后因为需求原因,希望实现的是用户的某个操作自动创建一个git的工作空间,然后用户可以配置一些东西,会用代码的形式以文件的形式push到git。最终可以通过某种方式直接将这个项目再k8s中运行起来。
另外希望可以将git项目中的文件和最后修改时间以列表的形式返回(因为有些人不想给git权限,但是给提供查看文件更新时间的功能)。

我负责的是简单的创建项目和push,展示文件列表。因为其实这个功能不是很常见,所以写的时候没有拿来主义,自己调试了好久,所以这里简单记录下:
一共分为三个接口:
create空git项目
push项目
拉取项目所有文件并获取最后修改时间

假设我有了有权限的token,申请方式是这样的:
注意一点,不是在git中可以crud就是有权限,可能git页面和接口的权限是不一样的,所以要在接口中有这个setting的账号申请的token才生效。


有权限的账号

然后有了token以后,进行创建(注意projectName是要创建的名称,apiUrl 是git地址,namespace_id是想要创建的目录的id):

    private static String token = "xx";
    public static void createProject(String projectName){
        try {
            HttpClient httpClient = HttpClients.createDefault();
            // 构建 API 请求 URL
            String apiUrl = "https://gitlab.xx.xxx.com/api/v4/projects";
            // 构建请求体 JSON 数据
            String requestBody = "{\"name\": \"" + projectName + "\",\"namespace_id\": 62296}";

            // 创建 POST 请求
            HttpPost httpPost = new HttpPost(apiUrl);
            httpPost.setHeader("Content-Type", "application/json");
            httpPost.setHeader("Private-Token", token);
            httpPost.setEntity(new StringEntity(requestBody, ContentType.APPLICATION_JSON));

            // 发送请求并获取响应
            HttpResponse response = httpClient.execute(httpPost);
            System.out.println(response);
            HttpEntity entity = response.getEntity();
            // 处理响应
            if (entity != null) {
                String responseString = entity.toString();
                System.out.println(responseString);
            }
        }catch (Exception e){
            e.printStackTrace();
        }
    }

提交文件:

public static String createAndAddFileToGitRepo(CamelProjectEntity camelProjectEntity,List<CamelDataEntity> list) {
        try {
            // Clone the Git repository
            File localPath = File.createTempFile("temp-git-repo", "");
            localPath.delete();
            CredentialsProvider credentialsProvider = new UsernamePasswordCredentialsProvider("userName", "password");
            Git git = Git.cloneRepository()
                    .setURI(camelProjectEntity.getGitAddress())
                    .setCredentialsProvider(credentialsProvider)
                    .setDirectory(localPath)
                    .call();
            // Create the file
            for (CamelDataEntity c : list) {
                String fileName = c.getName()+".yml";
                String content = c.getYml();
                // Create the file
                File file = new File(localPath.getPath() + File.separator + fileName);
                FileWriter writer = new FileWriter(file);
                writer.write(content);
                writer.close();
                // Add the file to the Git repository
                git.add()
                        .addFilepattern(fileName)
                        .call();
            }
            // Commit the changes
            git.commit()
                    .setMessage("Add files")
                    .call();

            // Push the changes to the remote repository
            git.push()
                    .setCredentialsProvider(credentialsProvider)
                    .call();
            // Clean up
            git.close();
            localPath.deleteOnExit();
            return "推送成功";
        }catch (Exception e){
            e.printStackTrace();
            return "推送失败";
        }

    }

最后一个方法比较麻烦,我直接附上完整的代码:

package com.lenovo.common.utils;

import org.eclipse.jgit.api.Git;
import org.eclipse.jgit.api.errors.GitAPIException;
import org.eclipse.jgit.diff.DiffEntry;
import org.eclipse.jgit.diff.DiffFormatter;
import org.eclipse.jgit.lib.Repository;
import org.eclipse.jgit.lib.RepositoryBuilder;
import org.eclipse.jgit.revwalk.RevCommit;
import org.eclipse.jgit.revwalk.RevWalk;
import org.eclipse.jgit.transport.UsernamePasswordCredentialsProvider;
import org.eclipse.jgit.util.io.DisabledOutputStream;

import java.io.File;
import java.io.IOException;
import java.nio.file.Files;
import java.text.SimpleDateFormat;
import java.util.*;

public class GitLastCommitTime {

    public static boolean deleteFile(String path) {
        File file = new File(path);
        if (!file.exists()) {
            System.out.println("File or directory does not exist.");
            return false;
        }
        if (file.isDirectory()) {
            // 如果是目录,则递归删除其中的文件和子目录
            File[] files = file.listFiles();
            if (files != null) {
                for (File subFile : files) {
                    deleteFile(subFile.getAbsolutePath());
                }
            }
        }
        // 删除文件或空目录
        return file.delete();
    }

    public static   Map<String, Object>  git(String gitRepoUrl){
        String username = "username ";
        String password = "password ";
        String name = gitRepoUrl;
        deleteFile(name);
        try (Git git = cloneRepository(gitRepoUrl, username, password)) {
            Repository repo = createRepository(git.getRepository());
            Map<String, Date> fileLastCommitTimeMap = getFileLastCommitTimeMap(repo);
            Iterator<Map.Entry<String, Date>> iterator = fileLastCommitTimeMap.entrySet().iterator();
            while (iterator.hasNext()) {
                Map.Entry<String, Date> entry = iterator.next();
                if (entry.getKey().contains(".git")) {
                    iterator.remove();
                }
            }
            Map<String, String> folderContentMap = readFolderContents(name);
            Map<String, Object> res = convertToTree(fileLastCommitTimeMap,name);
            return res;
        } catch (Exception e) {
            e.printStackTrace();
        }
        return null;
    }

    private static Map<String, String> readFolderContents(String folderPath) {
        Map<String, String> folderContentMap = new HashMap<>();
        File folder = new File(folderPath);

        if (!folder.isDirectory()) {
            throw new IllegalArgumentException("Specified path is not a valid folder.");
        }

        File[] files = folder.listFiles();

        for (File file : files) {
            if (file.isFile() && (file.getName().endsWith("xslt") || file.getName().endsWith("dfdl"))) {
                try {
                    String content = new String(Files.readAllBytes(file.toPath()));
                    folderContentMap.put(file.getName(), content);
                } catch (Exception e) {
                    e.printStackTrace();
                }
            } else if (file.isDirectory()) {
                folderContentMap.putAll(readFolderContents(file.getPath()));
            }
        }
        return folderContentMap;
    }

    public static Map<String, Object> convertToTree(Map<String, Date> fileLastModifiedMap,String name) {
        Map<String, Object> root = new HashMap<>();
        root.put("files", new HashMap<>());
        root.put("name", name);
        root.put("subfolders", new ArrayList<>());

        for (String filePath : fileLastModifiedMap.keySet()) {
            String[] folders = filePath.split("/");

            Map<String, Object> currentNode = root;
            for (int i = 0; i < folders.length - 1; i++) {
                String folder = folders[i];
                List<Map<String, Object>> subfolders = (List<Map<String, Object>>) currentNode.get("subfolders");
                Optional<Map<String, Object>> optionalFolder = subfolders.stream()
                        .filter(f -> f.get("name").equals(folder))
                        .findFirst();

                if (optionalFolder.isPresent()) {
                    currentNode = optionalFolder.get();
                } else {
                    Map<String, Object> newFolder = new HashMap<>();
                    newFolder.put("files", new HashMap<>());
                    newFolder.put("name", folder);
                    newFolder.put("subfolders", new ArrayList<>());

                    subfolders.add(newFolder);
                    currentNode = newFolder;
                }
            }

            String file = folders[folders.length - 1];
            Map<String,String> files = (Map<String,String>) currentNode.get("files");
            files.put(file,new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(fileLastModifiedMap.get(filePath)));
        }

        return root;
    }

    private static Git cloneRepository(String gitRepoUrl, String username, String password) throws GitAPIException {
        return Git.cloneRepository()
                .setURI(gitRepoUrl)
                .setCredentialsProvider(new UsernamePasswordCredentialsProvider(username, password))
                .call();
    }
    private static Repository createRepository(org.eclipse.jgit.lib.Repository jGitRepo) throws Exception {
        RepositoryBuilder builder = new RepositoryBuilder();
        builder.setGitDir(jGitRepo.getDirectory());
        builder.readEnvironment();

        return builder.build();
    }

    private static Map<String, Date> getFileLastCommitTimeMap(Repository repository) throws IOException {
        Map<String, Date> fileLastCommitTimeMap = new HashMap<>();

        try {
            org.eclipse.jgit.api.Git git = new org.eclipse.jgit.api.Git(repository);
            RevWalk revWalk = new RevWalk(repository);
            Iterable<RevCommit> commits = git.log().all().call();

            for (RevCommit commit : commits) {
                RevCommit parentCommit = null;

                if (commit.getParentCount() > 0) {
                    parentCommit = revWalk.parseCommit(commit.getParent(0).getId());
                }

                List<DiffEntry> diffs = getDiffEntries(repository, parentCommit, commit);

                for (DiffEntry diff : diffs) {
                    String filePath = diff.getNewPath();
                    Date lastCommitTime = fileLastCommitTimeMap.getOrDefault(filePath, new Date(0));
                    Date commitTime = new Date(commit.getCommitTime() * 1000L);

                    if (commitTime.after(lastCommitTime)) {
                        fileLastCommitTimeMap.put(filePath, commitTime);
                    }
                }
            }
        }catch (Exception e){
            e.printStackTrace();
        }

        return fileLastCommitTimeMap;
    }
    private static List<DiffEntry> getDiffEntries(Repository repository, RevCommit parentCommit, RevCommit commit) throws IOException {
        DiffFormatter diffFormatter = new DiffFormatter(DisabledOutputStream.INSTANCE);
        diffFormatter.setRepository(repository);
        diffFormatter.setDetectRenames(true);

        return diffFormatter.scan(parentCommit != null ? parentCommit.getTree() : null, commit.getTree());
    }

    class FileCommitInfo {
        private String filePath;
        private Date lastCommitTime;

        public FileCommitInfo(String filePath, Date lastCommitTime) {
            this.filePath = filePath;
            this.lastCommitTime = lastCommitTime;
        }

        public String getFilePath() {
            return filePath;
        }

        public Date getLastCommitTime() {
            return lastCommitTime;
        }
    }
}

最后这个方法因为步骤比较多,我全贴出来修改敏感词的,所以如果跑不通自己调试下就行了

本篇笔记就记到这里,如果稍微帮到你了记得点个喜欢点个关注~

©著作权归作者所有,转载或内容合作请联系作者
  • 序言:七十年代末,一起剥皮案震惊了整个滨河市,随后出现的几起案子,更是在滨河造成了极大的恐慌,老刑警刘岩,带你破解...
    沈念sama阅读 211,948评论 6 492
  • 序言:滨河连续发生了三起死亡事件,死亡现场离奇诡异,居然都是意外死亡,警方通过查阅死者的电脑和手机,发现死者居然都...
    沈念sama阅读 90,371评论 3 385
  • 文/潘晓璐 我一进店门,熙熙楼的掌柜王于贵愁眉苦脸地迎上来,“玉大人,你说我怎么就摊上这事。” “怎么了?”我有些...
    开封第一讲书人阅读 157,490评论 0 348
  • 文/不坏的土叔 我叫张陵,是天一观的道长。 经常有香客问我,道长,这世上最难降的妖魔是什么? 我笑而不...
    开封第一讲书人阅读 56,521评论 1 284
  • 正文 为了忘掉前任,我火速办了婚礼,结果婚礼上,老公的妹妹穿的比我还像新娘。我一直安慰自己,他们只是感情好,可当我...
    茶点故事阅读 65,627评论 6 386
  • 文/花漫 我一把揭开白布。 她就那样静静地躺着,像睡着了一般。 火红的嫁衣衬着肌肤如雪。 梳的纹丝不乱的头发上,一...
    开封第一讲书人阅读 49,842评论 1 290
  • 那天,我揣着相机与录音,去河边找鬼。 笑死,一个胖子当着我的面吹牛,可吹牛的内容都是我干的。 我是一名探鬼主播,决...
    沈念sama阅读 38,997评论 3 408
  • 文/苍兰香墨 我猛地睁开眼,长吁一口气:“原来是场噩梦啊……” “哼!你这毒妇竟也来了?” 一声冷哼从身侧响起,我...
    开封第一讲书人阅读 37,741评论 0 268
  • 序言:老挝万荣一对情侣失踪,失踪者是张志新(化名)和其女友刘颖,没想到半个月后,有当地人在树林里发现了一具尸体,经...
    沈念sama阅读 44,203评论 1 303
  • 正文 独居荒郊野岭守林人离奇死亡,尸身上长有42处带血的脓包…… 初始之章·张勋 以下内容为张勋视角 年9月15日...
    茶点故事阅读 36,534评论 2 327
  • 正文 我和宋清朗相恋三年,在试婚纱的时候发现自己被绿了。 大学时的朋友给我发了我未婚夫和他白月光在一起吃饭的照片。...
    茶点故事阅读 38,673评论 1 341
  • 序言:一个原本活蹦乱跳的男人离奇死亡,死状恐怖,灵堂内的尸体忽然破棺而出,到底是诈尸还是另有隐情,我是刑警宁泽,带...
    沈念sama阅读 34,339评论 4 330
  • 正文 年R本政府宣布,位于F岛的核电站,受9级特大地震影响,放射性物质发生泄漏。R本人自食恶果不足惜,却给世界环境...
    茶点故事阅读 39,955评论 3 313
  • 文/蒙蒙 一、第九天 我趴在偏房一处隐蔽的房顶上张望。 院中可真热闹,春花似锦、人声如沸。这庄子的主人今日做“春日...
    开封第一讲书人阅读 30,770评论 0 21
  • 文/苍兰香墨 我抬头看了看天上的太阳。三九已至,却和暖如春,着一层夹袄步出监牢的瞬间,已是汗流浃背。 一阵脚步声响...
    开封第一讲书人阅读 32,000评论 1 266
  • 我被黑心中介骗来泰国打工, 没想到刚下飞机就差点儿被人妖公主榨干…… 1. 我叫王不留,地道东北人。 一个月前我还...
    沈念sama阅读 46,394评论 2 360
  • 正文 我出身青楼,却偏偏与公主长得像,于是被迫代替她去往敌国和亲。 传闻我的和亲对象是个残疾皇子,可洞房花烛夜当晚...
    茶点故事阅读 43,562评论 2 349

推荐阅读更多精彩内容