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
|
/*
* 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 https://mozilla.org/MPL/2.0/.
*/
"use strict";
const EXPORTED_SYMBOLS = ["EnigmailStreams"];
const { XPCOMUtils } = ChromeUtils.importESModule(
"resource://gre/modules/XPCOMUtils.sys.mjs"
);
const lazy = {};
XPCOMUtils.defineLazyModuleGetters(lazy, {
NetUtil: "resource://gre/modules/NetUtil.jsm",
});
var EnigmailStreams = {
/**
* Create a new channel from a URL or URI.
*
* @param url: String, nsIURI or nsIFile - URL specification
*
* @return: channel
*/
createChannel(url) {
let c = lazy.NetUtil.newChannel({
uri: url,
loadUsingSystemPrincipal: true,
});
return c;
},
/**
* create an nsIStreamListener object to read String data from an nsIInputStream
*
* @onStopCallback: Function - function(data) that is called when the stream has stopped
* string data is passed as |data|
*
* @return: the nsIStreamListener to pass to the stream
*/
newStringStreamListener(onStopCallback) {
let listener = {
data: "",
inStream: Cc["@mozilla.org/binaryinputstream;1"].createInstance(
Ci.nsIBinaryInputStream
),
QueryInterface: ChromeUtils.generateQI([
"nsIStreamListener",
"nsIRequestObserver",
]),
onStartRequest(channel) {},
onStopRequest(channel, status) {
this.inStream = null;
onStopCallback(this.data);
},
};
listener.onDataAvailable = function (req, stream, offset, count) {
this.inStream.setInputStream(stream);
this.data += this.inStream.readBytes(count);
};
return listener;
},
/**
* create a nsIInputStream object that is fed with string data
*
* @uri: nsIURI - object representing the URI that will deliver the data
* @contentType: String - the content type as specified in nsIChannel
* @contentCharset: String - the character set; automatically determined if null
* @data: String - the data to feed to the stream
* @loadInfo nsILoadInfo - loadInfo (optional)
*
* @returns nsIChannel object
*/
newStringChannel(uri, contentType, contentCharset, data, loadInfo) {
if (!loadInfo) {
loadInfo = createLoadInfo();
}
let inputStream = Cc[
"@mozilla.org/io/string-input-stream;1"
].createInstance(Ci.nsIStringInputStream);
inputStream.setData(data, -1);
if (!contentCharset || contentCharset.length === 0) {
let netUtil = Services.io.QueryInterface(Ci.nsINetUtil);
const newCharset = {};
const hadCharset = {};
netUtil.parseResponseContentType(contentType, newCharset, hadCharset);
contentCharset = newCharset.value;
}
let isc = Cc["@mozilla.org/network/input-stream-channel;1"].createInstance(
Ci.nsIInputStreamChannel
);
isc.QueryInterface(Ci.nsIChannel);
isc.setURI(uri);
isc.loadInfo = loadInfo;
isc.contentStream = inputStream;
if (contentType && contentType.length) {
isc.contentType = contentType;
}
if (contentCharset && contentCharset.length) {
isc.contentCharset = contentCharset;
}
return isc;
},
newFileChannel(uri, file, contentType, deleteOnClose) {
let inputStream = Cc[
"@mozilla.org/network/file-input-stream;1"
].createInstance(Ci.nsIFileInputStream);
let behaviorFlags = Ci.nsIFileInputStream.CLOSE_ON_EOF;
if (deleteOnClose) {
behaviorFlags |= Ci.nsIFileInputStream.DELETE_ON_CLOSE;
}
const ioFlags = 0x01; // readonly
const perm = 0;
inputStream.init(file, ioFlags, perm, behaviorFlags);
let isc = Cc["@mozilla.org/network/input-stream-channel;1"].createInstance(
Ci.nsIInputStreamChannel
);
isc.QueryInterface(Ci.nsIChannel);
isc.contentDisposition = Ci.nsIChannel.DISPOSITION_ATTACHMENT;
isc.loadInfo = createLoadInfo();
isc.setURI(uri);
isc.contentStream = inputStream;
if (contentType && contentType.length) {
isc.contentType = contentType;
}
return isc;
},
};
function createLoadInfo() {
let c = lazy.NetUtil.newChannel({
uri: "chrome://openpgp/content/",
loadUsingSystemPrincipal: true,
});
return c.loadInfo;
}
|
