| // Copyright (C) 2019 The Android Open Source Project |
| // |
| // Licensed under the Apache License, Version 2.0 (the "License"); |
| // you may not use this file except in compliance with the License. |
| // You may obtain a copy of the License at |
| // |
| // http://www.apache.org/licenses/LICENSE-2.0 |
| // |
| // Unless required by applicable law or agreed to in writing, software |
| // distributed under the License is distributed on an "AS IS" BASIS, |
| // WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. |
| // See the License for the specific language governing permissions and |
| // limitations under the License. |
| |
| package com.google.gerrit.server.account.externalids.testing; |
| |
| import static com.google.gerrit.testing.TestActionRefUpdateContext.testRefAction; |
| import static java.nio.charset.StandardCharsets.UTF_8; |
| import static org.eclipse.jgit.lib.Constants.OBJ_BLOB; |
| import static org.eclipse.jgit.lib.Constants.OBJ_TREE; |
| |
| import com.google.gerrit.entities.Account; |
| import com.google.gerrit.entities.RefNames; |
| import com.google.gerrit.server.account.externalids.ExternalId; |
| import com.google.gerrit.server.account.externalids.storage.notedb.ExternalIdReader; |
| import java.io.IOException; |
| import org.eclipse.jgit.lib.CommitBuilder; |
| import org.eclipse.jgit.lib.Config; |
| import org.eclipse.jgit.lib.ObjectId; |
| import org.eclipse.jgit.lib.ObjectInserter; |
| import org.eclipse.jgit.lib.PersonIdent; |
| import org.eclipse.jgit.lib.RefUpdate; |
| import org.eclipse.jgit.lib.Repository; |
| import org.eclipse.jgit.notes.NoteMap; |
| import org.eclipse.jgit.revwalk.RevCommit; |
| import org.eclipse.jgit.revwalk.RevWalk; |
| |
| /** Common methods for dealing with external IDs in tests. */ |
| public class ExternalIdTestUtil { |
| |
| public static String insertExternalIdWithoutAccountId( |
| Repository repo, RevWalk rw, PersonIdent ident, Account.Id accountId, String externalId) |
| throws IOException { |
| return insertExternalId( |
| repo, |
| rw, |
| ident, |
| (ins, noteMap) -> { |
| ExternalId extId = |
| ExternalId.create( |
| ExternalId.Key.parse(externalId, false), accountId, null, null, null); |
| ObjectId noteId = extId.key().sha1(); |
| Config c = new Config(); |
| extId.writeToConfig(c); |
| c.unset("externalId", extId.key().get(), "accountId"); |
| byte[] raw = c.toText().getBytes(UTF_8); |
| ObjectId dataBlob = ins.insert(OBJ_BLOB, raw); |
| noteMap.set(noteId, dataBlob); |
| return noteId; |
| }); |
| } |
| |
| public static String insertExternalIdWithKeyThatDoesntMatchNoteId( |
| Repository repo, RevWalk rw, PersonIdent ident, Account.Id accountId, String externalId) |
| throws IOException { |
| return insertExternalId( |
| repo, |
| rw, |
| ident, |
| (ins, noteMap) -> { |
| ExternalId extId = |
| ExternalId.create( |
| ExternalId.Key.parse(externalId, false), accountId, null, null, null); |
| ObjectId noteId = ExternalId.Key.parse(externalId + "x", false).sha1(); |
| Config c = new Config(); |
| extId.writeToConfig(c); |
| byte[] raw = c.toText().getBytes(UTF_8); |
| ObjectId dataBlob = ins.insert(OBJ_BLOB, raw); |
| noteMap.set(noteId, dataBlob); |
| return noteId; |
| }); |
| } |
| |
| public static String insertExternalIdWithInvalidConfig( |
| Repository repo, RevWalk rw, PersonIdent ident, String externalId) throws IOException { |
| return insertExternalId( |
| repo, |
| rw, |
| ident, |
| (ins, noteMap) -> { |
| ObjectId noteId = ExternalId.Key.parse(externalId, false).sha1(); |
| byte[] raw = "bad-config".getBytes(UTF_8); |
| ObjectId dataBlob = ins.insert(OBJ_BLOB, raw); |
| noteMap.set(noteId, dataBlob); |
| return noteId; |
| }); |
| } |
| |
| public static String insertExternalIdWithEmptyNote( |
| Repository repo, RevWalk rw, PersonIdent ident, String externalId) throws IOException { |
| return insertExternalId( |
| repo, |
| rw, |
| ident, |
| (ins, noteMap) -> { |
| ObjectId noteId = ExternalId.Key.parse(externalId, false).sha1(); |
| byte[] raw = "".getBytes(UTF_8); |
| ObjectId dataBlob = ins.insert(OBJ_BLOB, raw); |
| noteMap.set(noteId, dataBlob); |
| return noteId; |
| }); |
| } |
| |
| private static String insertExternalId( |
| Repository repo, RevWalk rw, PersonIdent ident, ExternalIdInserter extIdInserter) |
| throws IOException { |
| ObjectId rev = ExternalIdReader.readRevision(repo); |
| NoteMap noteMap = ExternalIdReader.readNoteMap(rw, rev); |
| |
| try (ObjectInserter ins = repo.newObjectInserter()) { |
| ObjectId noteId = extIdInserter.addNote(ins, noteMap); |
| |
| CommitBuilder cb = new CommitBuilder(); |
| cb.setMessage("Update external IDs"); |
| cb.setTreeId(noteMap.writeTree(ins)); |
| cb.setAuthor(ident); |
| cb.setCommitter(ident); |
| if (!rev.equals(ObjectId.zeroId())) { |
| cb.setParentId(rev); |
| } else { |
| cb.setParentIds(); // Ref is currently nonexistent, commit has no parents. |
| } |
| if (cb.getTreeId() == null) { |
| if (rev.equals(ObjectId.zeroId())) { |
| cb.setTreeId(ins.insert(OBJ_TREE, new byte[] {})); // No parent, assume empty tree. |
| } else { |
| RevCommit p = rw.parseCommit(rev); |
| cb.setTreeId(p.getTree()); // Copy tree from parent. |
| } |
| } |
| ObjectId commitId = ins.insert(cb); |
| ins.flush(); |
| |
| RefUpdate u = repo.updateRef(RefNames.REFS_EXTERNAL_IDS); |
| u.setExpectedOldObjectId(rev); |
| u.setNewObjectId(commitId); |
| RefUpdate.Result res = testRefAction(() -> u.update()); |
| switch (res) { |
| case NEW: |
| case FAST_FORWARD: |
| case NO_CHANGE: |
| case RENAMED: |
| case FORCED: |
| break; |
| case LOCK_FAILURE: |
| case IO_FAILURE: |
| case NOT_ATTEMPTED: |
| case REJECTED: |
| case REJECTED_CURRENT_BRANCH: |
| case REJECTED_MISSING_OBJECT: |
| case REJECTED_OTHER_REASON: |
| default: |
| throw new IOException("Updating external IDs failed with " + res); |
| } |
| return noteId.getName(); |
| } |
| } |
| } |