+ * See SWIFT message structure, MT message format, MT999 + *
+ *+ * Copyright 2019, p≡p + * Security. + *
+ * + * @author Volker Birk + * @version %I% %G% + */ + +// FIXME: rework to stringbuffer + +public class MTMsgCodec { + public Engine pEp; + + /** + * Constructs a MessageCodec using p≡p engine. + * + * @param pEp_engine p≡p engine to use + */ + + public MTMsgCodec(Engine pEp_engine) { + pEp = pEp_engine; + } + + private final static String magicKeys = "pEpKeys"; + private final static String magicEnc = "pEpMessage"; + + private final static String pgp_regex = "(?ms)" + "-----BEGIN PGP (?pgp_text without PGP header
+ */
+
+ protected static String stripFromPGP(String pgp_text) throws ParseException {
+
+ Matcher m = pgp_pattern.matcher(pgp_text);
+ if (!m.matches())
+ throw new ParseException("not a PGP block", 0);
+
+ return m.group("block");
+ }
+
+ /**
+ * Adds PGP header and footer.
+ *
+ * @param payload text to decorate
+ * @param pgp_type PGP data type
+ * @return payload with added header and footer
+ */
+
+ protected static String addPGPHeader(String payload, String pgp_type) {
+ // FIXME: rework to stringbuffer
+ return "-----BEGIN PGP " + pgp_type + "-----\n\n" + payload + "\n-----END PGP " + pgp_type + "-----\n";
+ }
+
+ /**
+ * Decodes a BIC from an URI.
+ *
+ * @param uri the URI to decode from
+ * @throws ParseException if URI has not the correct form
+ * @return decoded BIC
+ */
+
+ public static String decodeBIC(String uri) throws ParseException {
+ Matcher m = uri_pattern.matcher(uri);
+ if (!m.matches())
+ throw new ParseException("not a valid URI", 0);
+
+ return m.group("bic");
+ }
+
+ /**
+ * Encodes a BIC into an URI.
+ *
+ * @param bic BIC to encode
+ * @return encoded URI
+ */
+
+ public static String encodeBIC(String bic) {
+ // return "payto://swift/" + bic
+ return bic + "@BIC";
+ }
+
+ /**
+ * Generates a list of transporting MT999 messages for a payload.
+ *
+ * @param from source address
+ * @param to destination address
+ * @param ii message direction
+ * @param trn message id
+ * @param payload payload to split
+ * @param magic magic string to mark as p≡p message
+ *
+ * @return array of String with MT999 messages
+ */
+
+ protected String[] transportMT999(String from, String to, String ii, String trn, String rr, String payload,
+ String magic) {
+
+ Vectorlongmsg; in this case
+ * message direction is being taken from there, too
+ * @param config properties with configuration
+ * @return String with encoded p≡p for SWIFT message
+ * @throws UnsupportedOperationException if EncFormat is other than
+ * None, Inline
+ * or PEP
+ */
+
+ public String encode(Message msg, Properties config) {
+ if (msg.getLongmsg() == null || msg.getLongmsg().length() < 1)
+ throw new IllegalArgumentException("longmsg must contain the message");
+
+ String result = "";
+
+ String msgid = msg.getId() != null && msg.getId().length() > 0 ? msg.getId() : "23";
+ String dir = msg.getDir() == Message.Direction.Incoming ? "I" : "O";
+
+ if (msgid.length() > 12) {
+ if (msgid.substring(0, 3).compareTo("pEp.") == 0 && msgid.length() >= 15)
+ msgid = msgid.substring(4, 15);
+ else
+ msgid = msgid.substring(0, 11);
+ }
+
+ String from = msg.getFrom() != null && msg.getFrom().address.length() > 0 ? msg.getFrom().address : null;
+
+ String to = msg.getTo() != null && msg.getTo().size() > 0 && msg.getTo().elementAt(0).address.length() > 0
+ ? msg.getTo().elementAt(0).address
+ : null;
+
+ if (from != null) {
+ try {
+ from = decodeBIC(from);
+ if (from.length() != 12)
+ throw new IllegalArgumentException("from address must be URI with BIC12");
+ } catch (ParseException ex) {
+ throw new IllegalArgumentException("from address must be URI with BIC12");
+ }
+ }
+
+ if (to != null) {
+ try {
+ to = decodeBIC(to);
+ if (to.length() != 12)
+ throw new IllegalArgumentException("to address must be URI with BIC12");
+ } catch (ParseException ex) {
+ throw new IllegalArgumentException("to address must be URI with BIC12");
+ }
+ }
+
+ switch (msg.getEncFormat()) {
+ case None:
+ result = msg.getLongmsg(); // we send the message unmodified
+ if (result.substring(0, 3).compareTo("{1:") == 0) {
+ // probably SWIFT MTFIN
+
+ if (from == null || to == null || msgid == null) {
+ // parse SWIFT header
+ SWIFTMsg mh = new SWIFTMsg();
+
+ try {
+ mh.parseHeader(result);
+ } catch (ParseException ex) {
+ throw new UnsupportedOperationException("unsupported message format");
+ }
+
+ if (from == null)
+ from = mh.logicalTerminalAddress;
+ if (to == null)
+ to = mh.destinationAddress;
+ dir = mh.inputIdentifier;
+ }
+ } else if (result.substring(0, 1).compareTo("<") == 0) {
+ // probably XML
+
+ // FIXME: let's do the job for MTXML, too
+ return result;
+ } else { // we don't know this format, so let it be
+ return result;
+ }
+
+ if(msg.getAttachments() != null)
+ for (int i = 0; i < msg.getAttachments().size(); ++i) { // FIXME: can attachments become null?
+ Blob attach = msg.getAttachments().elementAt(i);
+ String magic;
+
+ if (attach.mime_type.compareToIgnoreCase("application/pgp-keys") == 0)
+ magic = magicKeys;
+ else
+ break; // don't know this MIME type
+
+ // we send an MT999 with the keys
+ String payload;
+ try {
+ payload = stripFromPGP(new String(attach.data, StandardCharsets.UTF_8));
+ } catch (ParseException ex) {
+ // cannot parse this
+ break;
+ }
+
+ String[] msgs = transportMT999(from, to, dir, msgid, "", payload, magic);
+
+ for (int j = 0; j < msgs.length; ++j) {
+ if (j > 0)
+ result += "\n";
+ result += msgs[j].toString();
+ }
+ }
+ break;
+
+ case PEP:
+ case PGPMIME:
+ case Inline:
+ if (from == null || to == null)
+ throw new IllegalArgumentException("from and to must be set to URIs with BIC12");
+
+ String pgp_txt;
+ Vector