1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
|
/* This Source Code Form is subject to the terms of the Mozilla Public
* License, v. 2.0. If a copy of the MPL was not distributed with this
* file, You can obtain one at http://mozilla.org/MPL/2.0/. */
package org.mozilla.gecko.sync.middleware;
import java.util.concurrent.ExecutorService;
import org.mozilla.gecko.background.common.log.Logger;
import org.mozilla.gecko.sync.repositories.InactiveSessionException;
import org.mozilla.gecko.sync.repositories.InvalidSessionTransitionException;
import org.mozilla.gecko.sync.repositories.RepositorySession;
import org.mozilla.gecko.sync.repositories.RepositorySessionBundle;
import org.mozilla.gecko.sync.repositories.delegates.RepositorySessionBeginDelegate;
import org.mozilla.gecko.sync.repositories.delegates.RepositorySessionFinishDelegate;
import org.mozilla.gecko.sync.repositories.delegates.RepositorySessionGuidsSinceDelegate;
import org.mozilla.gecko.sync.repositories.delegates.RepositorySessionWipeDelegate;
public abstract class MiddlewareRepositorySession extends RepositorySession {
private static final String LOG_TAG = "MiddlewareSession";
protected final RepositorySession inner;
public MiddlewareRepositorySession(RepositorySession innerSession, MiddlewareRepository repository) {
super(repository);
this.inner = innerSession;
}
@Override
public void wipe(RepositorySessionWipeDelegate delegate) {
inner.wipe(delegate);
}
public class MiddlewareRepositorySessionBeginDelegate implements RepositorySessionBeginDelegate {
private final MiddlewareRepositorySession outerSession;
private final RepositorySessionBeginDelegate next;
public MiddlewareRepositorySessionBeginDelegate(MiddlewareRepositorySession outerSession, RepositorySessionBeginDelegate next) {
this.outerSession = outerSession;
this.next = next;
}
@Override
public void onBeginFailed(Exception ex) {
next.onBeginFailed(ex);
}
@Override
public void onBeginSucceeded(RepositorySession session) {
next.onBeginSucceeded(outerSession);
}
@Override
public RepositorySessionBeginDelegate deferredBeginDelegate(ExecutorService executor) {
final RepositorySessionBeginDelegate deferred = next.deferredBeginDelegate(executor);
return new RepositorySessionBeginDelegate() {
@Override
public void onBeginSucceeded(RepositorySession session) {
if (inner != session) {
Logger.warn(LOG_TAG, "Got onBeginSucceeded for session " + session + ", not our inner session!");
}
deferred.onBeginSucceeded(outerSession);
}
@Override
public void onBeginFailed(Exception ex) {
deferred.onBeginFailed(ex);
}
@Override
public RepositorySessionBeginDelegate deferredBeginDelegate(ExecutorService executor) {
return this;
}
};
}
}
@Override
public void begin(RepositorySessionBeginDelegate delegate) throws InvalidSessionTransitionException {
inner.begin(new MiddlewareRepositorySessionBeginDelegate(this, delegate));
}
public class MiddlewareRepositorySessionFinishDelegate implements RepositorySessionFinishDelegate {
private final MiddlewareRepositorySession outerSession;
private final RepositorySessionFinishDelegate next;
public MiddlewareRepositorySessionFinishDelegate(MiddlewareRepositorySession outerSession, RepositorySessionFinishDelegate next) {
this.outerSession = outerSession;
this.next = next;
}
@Override
public void onFinishFailed(Exception ex) {
next.onFinishFailed(ex);
}
@Override
public void onFinishSucceeded(RepositorySession session, RepositorySessionBundle bundle) {
next.onFinishSucceeded(outerSession, bundle);
}
@Override
public RepositorySessionFinishDelegate deferredFinishDelegate(ExecutorService executor) {
return this;
}
}
@Override
public void finish(RepositorySessionFinishDelegate delegate) throws InactiveSessionException {
inner.finish(new MiddlewareRepositorySessionFinishDelegate(this, delegate));
}
@Override
public synchronized void ensureActive() throws InactiveSessionException {
inner.ensureActive();
}
@Override
public synchronized boolean isActive() {
return inner.isActive();
}
@Override
public synchronized SessionStatus getStatus() {
return inner.getStatus();
}
@Override
public synchronized void setStatus(SessionStatus status) {
inner.setStatus(status);
}
@Override
public synchronized void transitionFrom(SessionStatus from, SessionStatus to)
throws InvalidSessionTransitionException {
inner.transitionFrom(from, to);
}
@Override
public void abort() {
inner.abort();
}
@Override
public void abort(RepositorySessionFinishDelegate delegate) {
inner.abort(new MiddlewareRepositorySessionFinishDelegate(this, delegate));
}
@Override
public void guidsSince(long timestamp, RepositorySessionGuidsSinceDelegate delegate) {
// TODO: need to do anything here?
inner.guidsSince(timestamp, delegate);
}
@Override
public void storeDone() {
inner.storeDone();
}
@Override
public void storeDone(long storeEnd) {
inner.storeDone(storeEnd);
}
@Override
public boolean shouldSkip() {
return inner.shouldSkip();
}
@Override
public boolean dataAvailable() {
return inner.dataAvailable();
}
@Override
public void unbundle(RepositorySessionBundle bundle) {
inner.unbundle(bundle);
}
@Override
public long getLastSyncTimestamp() {
return inner.getLastSyncTimestamp();
}
}
|
