Details
diff --git a/util/src/main/java/com/ning/billing/util/tag/api/DefaultTagUserApi.java b/util/src/main/java/com/ning/billing/util/tag/api/DefaultTagUserApi.java
index 2ae5b3a..b3a93b4 100644
--- a/util/src/main/java/com/ning/billing/util/tag/api/DefaultTagUserApi.java
+++ b/util/src/main/java/com/ning/billing/util/tag/api/DefaultTagUserApi.java
@@ -153,7 +153,7 @@ public class DefaultTagUserApi implements TagUserApi {
@Override
public List<Tag> getTagsForAccount(final UUID accountId, final TenantContext context) {
- return withModelTransform(tagDao.getTagsForAccount(accountId, internalCallContextFactory.createInternalTenantContext(accountId, context)));
+ return withModelTransform(tagDao.getTagsForAccount(internalCallContextFactory.createInternalTenantContext(accountId, context)));
}
private List<Tag> withModelTransform(final List<TagModelDao> input) {
diff --git a/util/src/main/java/com/ning/billing/util/tag/dao/DefaultTagDao.java b/util/src/main/java/com/ning/billing/util/tag/dao/DefaultTagDao.java
index a75f585..888638b 100644
--- a/util/src/main/java/com/ning/billing/util/tag/dao/DefaultTagDao.java
+++ b/util/src/main/java/com/ning/billing/util/tag/dao/DefaultTagDao.java
@@ -80,7 +80,7 @@ public class DefaultTagDao extends EntityDaoBase<TagModelDao, Tag, TagApiExcepti
@Override
public List<TagModelDao> getTagsForAccountType(final UUID accountId, final ObjectType objectType, final InternalTenantContext internalTenantContext) {
- final List<TagModelDao> allTags = getTagsForAccount(accountId, internalTenantContext);
+ final List<TagModelDao> allTags = getTagsForAccount(internalTenantContext);
return ImmutableList.<TagModelDao>copyOf(Collections2.filter(allTags, new Predicate<TagModelDao>() {
@Override
public boolean apply(@Nullable final TagModelDao input) {
@@ -90,8 +90,7 @@ public class DefaultTagDao extends EntityDaoBase<TagModelDao, Tag, TagApiExcepti
}
@Override
- public List<TagModelDao> getTagsForAccount(final UUID accountId, final InternalTenantContext internalTenantContext) {
-
+ public List<TagModelDao> getTagsForAccount(final InternalTenantContext internalTenantContext) {
return transactionalSqlDao.execute(new EntitySqlDaoTransactionWrapper<List<TagModelDao>>() {
@Override
public List<TagModelDao> inTransaction(final EntitySqlDaoWrapperFactory<EntitySqlDao> entitySqlDaoWrapperFactory) throws Exception {
@@ -100,7 +99,6 @@ public class DefaultTagDao extends EntityDaoBase<TagModelDao, Tag, TagApiExcepti
});
}
-
@Override
protected void postBusEventFromTransaction(final TagModelDao tag, final TagModelDao savedTag, final ChangeType changeType,
final EntitySqlDaoWrapperFactory<EntitySqlDao> entitySqlDaoWrapperFactory, final InternalCallContext context)
diff --git a/util/src/main/java/com/ning/billing/util/tag/dao/TagDao.java b/util/src/main/java/com/ning/billing/util/tag/dao/TagDao.java
index c9e70c5..152115a 100644
--- a/util/src/main/java/com/ning/billing/util/tag/dao/TagDao.java
+++ b/util/src/main/java/com/ning/billing/util/tag/dao/TagDao.java
@@ -36,5 +36,5 @@ public interface TagDao {
List<TagModelDao> getTagsForAccountType(UUID accountId, ObjectType objectType, InternalTenantContext internalTenantContext);
- List<TagModelDao> getTagsForAccount(UUID accountId, InternalTenantContext internalTenantContext);
+ List<TagModelDao> getTagsForAccount(InternalTenantContext internalTenantContext);
}
diff --git a/util/src/test/java/com/ning/billing/util/tag/dao/MockTagDao.java b/util/src/test/java/com/ning/billing/util/tag/dao/MockTagDao.java
index 3e10f62..5653a7f 100644
--- a/util/src/test/java/com/ning/billing/util/tag/dao/MockTagDao.java
+++ b/util/src/test/java/com/ning/billing/util/tag/dao/MockTagDao.java
@@ -84,7 +84,7 @@ public class MockTagDao implements TagDao {
}
@Override
- public List<TagModelDao> getTagsForAccount(final UUID accountId, final InternalTenantContext internalTenantContext) {
+ public List<TagModelDao> getTagsForAccount(final InternalTenantContext internalTenantContext) {
throw new UnsupportedOperationException();
}
diff --git a/util/src/test/java/com/ning/billing/util/tag/dao/TestDefaultTagDao.java b/util/src/test/java/com/ning/billing/util/tag/dao/TestDefaultTagDao.java
index ff33436..ab76d25 100644
--- a/util/src/test/java/com/ning/billing/util/tag/dao/TestDefaultTagDao.java
+++ b/util/src/test/java/com/ning/billing/util/tag/dao/TestDefaultTagDao.java
@@ -21,12 +21,9 @@ import java.util.List;
import java.util.UUID;
import org.testng.Assert;
-import org.testng.annotations.AfterMethod;
-import org.testng.annotations.BeforeMethod;
import org.testng.annotations.Test;
import com.ning.billing.ObjectType;
-import com.ning.billing.api.TestApiListener;
import com.ning.billing.api.TestApiListener.NextEvent;
import com.ning.billing.util.UtilTestSuiteWithEmbeddedDB;
import com.ning.billing.util.api.TagDefinitionApiException;
@@ -141,17 +138,10 @@ public class TestDefaultTagDao extends UtilTestSuiteWithEmbeddedDB {
final List<TagModelDao> foundTags = tagDao.getTagsForObject(objectId, objectType, internalCallContext);
Assert.assertEquals(foundTags.size(), 1);
Assert.assertEquals(foundTags.get(0).getTagDefinitionId(), createdTagDefinition.getId());
+ final List<TagModelDao> foundTagsForAccount = tagDao.getTagsForAccount(internalCallContext);
+ Assert.assertEquals(foundTagsForAccount.size(), 1);
+ Assert.assertEquals(foundTagsForAccount.get(0).getTagDefinitionId(), createdTagDefinition.getId());
-/*
- TODO verify that event content matches what we expect
- // Verify we caught an event on the bus - we got 2 total (one for the tag definition, one for the tag)
- Assert.assertEquals(tagFirstEventReceived.getObjectId(), objectId);
- Assert.assertEquals(tagFirstEventReceived.getObjectType(), objectType);
- Assert.assertEquals(tagFirstEventReceived.getTagDefinition().getName(), createdTagDefinition.getName());
- Assert.assertEquals(tagFirstEventReceived.getTagDefinition().getDescription(), createdTagDefinition.getDescription());
- Assert.assertEquals(tagFirstEventReceived.getBusEventType(), BusInternalEvent.BusInternalEventType.USER_TAG_CREATION);
- Assert.assertEquals(tagFirstEventReceived.getUserToken(), internalCallContext.getUserToken());
-*/
// Delete the tag
eventsListener.pushExpectedEvent(NextEvent.TAG);
tagDao.deleteTag(objectId, objectType, createdTagDefinition.getId(), internalCallContext);
@@ -159,15 +149,6 @@ public class TestDefaultTagDao extends UtilTestSuiteWithEmbeddedDB {
// Make sure the tag is deleted
Assert.assertEquals(tagDao.getTagsForObject(objectId, objectType, internalCallContext).size(), 0);
-
- /*
- final TagInternalEvent tagSecondEventReceived = eventsListener.getTagEvents().get(1);
- Assert.assertEquals(tagSecondEventReceived.getObjectId(), objectId);
- Assert.assertEquals(tagSecondEventReceived.getObjectType(), objectType);
- Assert.assertEquals(tagSecondEventReceived.getTagDefinition().getName(), createdTagDefinition.getName());
- Assert.assertEquals(tagSecondEventReceived.getTagDefinition().getDescription(), createdTagDefinition.getDescription());
- Assert.assertEquals(tagSecondEventReceived.getBusEventType(), BusInternalEvent.BusInternalEventType.USER_TAG_DELETION);
- Assert.assertEquals(tagSecondEventReceived.getUserToken(), internalCallContext.getUserToken());
- */
+ Assert.assertEquals(tagDao.getTagsForAccount(internalCallContext).size(), 0);
}
}