Compare commits

...

1 Commits

Author SHA1 Message Date
Torsten Grote
362b3f396f Remove response messages right after storing them 2018-11-27 11:43:54 -02:00
3 changed files with 18 additions and 0 deletions

View File

@@ -29,6 +29,7 @@ import java.util.Map;
import javax.annotation.Nullable; import javax.annotation.Nullable;
import javax.annotation.concurrent.Immutable; import javax.annotation.concurrent.Immutable;
import static java.util.logging.Logger.getLogger;
import static org.briarproject.briar.introduction.MessageType.ABORT; import static org.briarproject.briar.introduction.MessageType.ABORT;
import static org.briarproject.briar.introduction.MessageType.ACCEPT; import static org.briarproject.briar.introduction.MessageType.ACCEPT;
import static org.briarproject.briar.introduction.MessageType.ACTIVATE; import static org.briarproject.briar.introduction.MessageType.ACTIVATE;
@@ -140,6 +141,11 @@ abstract class AbstractProtocolEngine<S extends Session>
visibleInConversation); visibleInConversation);
try { try {
clientHelper.addLocalMessage(txn, m, meta, true); clientHelper.addLocalMessage(txn, m, meta, true);
if (type != MessageType.REQUEST) {
getLogger("TEST").warning("DELETED MESSAGE AND METADATA");
db.deleteMessage(txn, m.getId());
db.deleteMessageMetadata(txn, m.getId());
}
} catch (FormatException e) { } catch (FormatException e) {
throw new AssertionError(e); throw new AssertionError(e);
} }

View File

@@ -29,6 +29,7 @@ import java.util.Map;
import javax.annotation.Nullable; import javax.annotation.Nullable;
import javax.annotation.concurrent.Immutable; import javax.annotation.concurrent.Immutable;
import static java.util.logging.Logger.getLogger;
import static org.briarproject.briar.api.privategroup.PrivateGroupManager.CLIENT_ID; import static org.briarproject.briar.api.privategroup.PrivateGroupManager.CLIENT_ID;
import static org.briarproject.briar.api.privategroup.PrivateGroupManager.MAJOR_VERSION; import static org.briarproject.briar.api.privategroup.PrivateGroupManager.MAJOR_VERSION;
import static org.briarproject.briar.privategroup.invitation.GroupInvitationConstants.GROUP_KEY_CONTACT_ID; import static org.briarproject.briar.privategroup.invitation.GroupInvitationConstants.GROUP_KEY_CONTACT_ID;
@@ -224,6 +225,11 @@ abstract class AbstractProtocolEngine<S extends Session>
true, visibleInConversation, false, false); true, visibleInConversation, false, false);
try { try {
clientHelper.addLocalMessage(txn, m, meta, true); clientHelper.addLocalMessage(txn, m, meta, true);
if (type != MessageType.INVITE) {
getLogger("TEST").warning("DELETED MESSAGE AND METADATA");
db.deleteMessage(txn, m.getId());
db.deleteMessageMetadata(txn, m.getId());
}
} catch (FormatException e) { } catch (FormatException e) {
throw new AssertionError(e); throw new AssertionError(e);
} }

View File

@@ -28,6 +28,7 @@ import java.util.Map;
import javax.annotation.Nullable; import javax.annotation.Nullable;
import javax.annotation.concurrent.Immutable; import javax.annotation.concurrent.Immutable;
import static java.util.logging.Logger.getLogger;
import static org.briarproject.bramble.api.sync.Group.Visibility.INVISIBLE; import static org.briarproject.bramble.api.sync.Group.Visibility.INVISIBLE;
import static org.briarproject.bramble.api.sync.Group.Visibility.SHARED; import static org.briarproject.bramble.api.sync.Group.Visibility.SHARED;
import static org.briarproject.bramble.api.sync.Group.Visibility.VISIBLE; import static org.briarproject.bramble.api.sync.Group.Visibility.VISIBLE;
@@ -568,6 +569,11 @@ abstract class ProtocolEngineImpl<S extends Shareable>
visibleInConversation, false, false); visibleInConversation, false, false);
try { try {
clientHelper.addLocalMessage(txn, m, meta, true); clientHelper.addLocalMessage(txn, m, meta, true);
if (type != MessageType.INVITE) {
getLogger("TEST").warning("DELETED MESSAGE AND METADATA");
db.deleteMessage(txn, m.getId());
db.deleteMessageMetadata(txn, m.getId());
}
} catch (FormatException e) { } catch (FormatException e) {
throw new AssertionError(e); throw new AssertionError(e);
} }