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
|
// $Id$
//
// Copyright (C) 2011 Greg Landrum
//
// @@ All Rights Reserved @@
// This file is part of the RDKit.
// The contents are covered by the terms of the BSD license
// which is included in the file license.txt, found at the root
// of the RDKit source tree.
//
#define NO_IMPORT_ARRAY
#include <RDBoost/python.h>
#include <string>
#include <fstream>
// ours
#include <RDGeneral/BadFileException.h>
#include <GraphMol/FileParsers/MolSupplier.h>
#include <GraphMol/RDKitBase.h>
#include <RDBoost/python_streambuf.h>
#include <RDBoost/iterator_next.h>
#include "MolSupplier.h"
namespace python = boost::python;
using boost_adaptbx::python::streambuf;
namespace {
class LocalForwardSDMolSupplier : public RDKit::ForwardSDMolSupplier {
public:
LocalForwardSDMolSupplier(python::object &input, bool sanitize, bool removeHs,
bool strictParsing) {
// FIX: minor leak here
auto *sb = new streambuf(input);
dp_inStream = new streambuf::istream(*sb);
df_owner = true;
df_sanitize = sanitize;
df_removeHs = removeHs;
df_strictParsing = strictParsing;
POSTCONDITION(dp_inStream, "bad instream");
}
LocalForwardSDMolSupplier(streambuf &input, bool sanitize, bool removeHs,
bool strictParsing) {
dp_inStream = new streambuf::istream(input);
df_owner = true;
df_sanitize = sanitize;
df_removeHs = removeHs;
df_strictParsing = strictParsing;
POSTCONDITION(dp_inStream, "bad instream");
}
LocalForwardSDMolSupplier(std::string filename, bool sanitize, bool removeHs,
bool strictParsing) {
std::istream *tmpStream = nullptr;
tmpStream = static_cast<std::istream *>(
new std::ifstream(filename.c_str(), std::ios_base::binary));
if (!tmpStream || (!(*tmpStream)) || (tmpStream->bad())) {
std::ostringstream errout;
errout << "Bad input file " << filename;
throw RDKit::BadFileException(errout.str());
}
dp_inStream = tmpStream;
df_owner = true;
df_sanitize = sanitize;
df_removeHs = removeHs;
df_strictParsing = strictParsing;
POSTCONDITION(dp_inStream, "bad instream");
}
};
LocalForwardSDMolSupplier *FwdMolSupplIter(LocalForwardSDMolSupplier *self) {
return self;
}
}
namespace RDKit {
std::string fsdMolSupplierClassDoc =
"A class which supplies molecules from file-like object containing SD data.\n\
\n\
Usage examples:\n\
\n\
1) Lazy evaluation: the molecules are not constructed until we ask for them:\n\
>>> suppl = ForwardSDMolSupplier(file('in.sdf'))\n\
>>> for mol in suppl:\n\
... if mol is not None: mol.GetNumAtoms()\n\
\n\
2) we can also read from compressed files: \n\
>>> import gzip\n\
>>> suppl = ForwardSDMolSupplier(gzip.open('in.sdf.gz'))\n\
>>> for mol in suppl:\n \
... if mol is not None: print mol.GetNumAtoms()\n\
\n\
Properties in the SD file are used to set properties on each molecule.\n\
The properties are accessible using the mol.GetProp(propName) method.\n\
\n";
struct forwardsdmolsup_wrap {
static void wrap() {
python::class_<LocalForwardSDMolSupplier, boost::noncopyable>(
"ForwardSDMolSupplier", fsdMolSupplierClassDoc.c_str(), python::no_init)
.def(python::init<python::object &, bool, bool, bool>(
(python::arg("fileobj"), python::arg("sanitize") = true,
python::arg("removeHs") = true,
python::arg("strictParsing") =
true))[python::with_custodian_and_ward_postcall<0, 2>()])
.def(python::init<streambuf &, bool, bool, bool>(
(python::arg("streambuf"), python::arg("sanitize") = true,
python::arg("removeHs") = true,
python::arg("strictParsing") =
true))[python::with_custodian_and_ward_postcall<0, 2>()])
.def(python::init<std::string, bool, bool, bool>(
(python::arg("filename"), python::arg("sanitize") = true,
python::arg("removeHs") = true,
python::arg("strictParsing") = true)))
.def(NEXT_METHOD,
(ROMol * (*)(LocalForwardSDMolSupplier *)) & MolSupplNext,
"Returns the next molecule in the file. Raises _StopIteration_ "
"on EOF.\n",
python::return_value_policy<python::manage_new_object>())
.def("atEnd", &ForwardSDMolSupplier::atEnd,
"Returns whether or not we have hit EOF.\n")
.def("__iter__", &FwdMolSupplIter,
python::return_internal_reference<1>());
};
};
}
void wrap_forwardsdsupplier() { RDKit::forwardsdmolsup_wrap::wrap(); }
|
