~ubuntu-branches/ubuntu/raring/eucalyptus/raring

@JoinTable(name = "auth_user_has_x509", joinColumns = [ @JoinColumn( name = "auth_user_id" ) ],inverseJoinColumns = [ @JoinColumn( name = "auth_x509_id" ) ])

136

@Cache( usage = CacheConcurrencyStrategy.READ_WRITE )

137

List<X509Cert> certificates = [];

138

139

@Transient

140

List<String> eucaGroupIds = [];

141

142

public UserEntity(){

143

}

144

145

public User getDelegate( ) {

146

return this;

147

}

148

149

public UserEntity( String userName ){

150

this.name = userName

151

}

152

153

public UserEntity( String userName, Boolean enabled ){

154

this(userName);

155

this.setEnabled( enabled );

156

}

157

158

public void revokeX509Certificate() {

159

for( X509Cert cert : this.getCertificates() ) {

160

cert.setRevoked(true);

161

}

162

LOG.debug("Current certificate for ${this.getName()}: ${this.getX509Certificate()?.getSerialNumber()}");

163

}

164

165

public void revokeSecretKey() {

166

this.setSecretKey( null );

167

}

168

169

public List<X509Certificate> getAllX509Certificates() {

170

List<X509Certificate> certs = Lists.newArrayList( );

171

for( X509Cert c : this.getCertificates() ) {

172

certs.add( X509Cert.toCertificate( c ) );

173

}

174

return certs;

175

}

176

177

public X509Certificate getX509Certificate() {

178

for( X509Cert cert : this.getCertificates() ) {

179

if( !cert.getRevoked( ) ) {

180

return X509Cert.toCertificate( cert );

181

}

182

}

183

return null;

184

}

185

186

public boolean checkToken( String token ) {

187

return this.getToken( ).equals( token )

188

}

189

190

public void setX509Certificate( X509Certificate x509 ) {

191

LOG.debug( "Setting new user certificate: " + x509.getSubjectX500Principal( ) + " " + x509.getSerialNumber( ) );

192

this.getCertificates( ).add( X509Cert.fromCertificate( x509 ) );

193

}

194

public Boolean isEnabled() {

195

return enabled;

196

}

197

public Boolean isAdministrator() {

198

return administrator;

199

}

200

public BigInteger getNumber() {

201

return new BigInteger( this.getId(), 16 );

202

}

203

@Override

204

public int hashCode( ) {

205

final int prime = 31;

206

int result = 1;

207

result = prime * result + ( ( name == null ) ? 0 : name.hashCode( ) );

208

return result;

209

}

210

@Override

211

public boolean equals( Object obj ) {

212

if ( this.is( obj ) ) return true;

213

if ( getClass( ).is( obj.getClass( ) ) ) return false;

214

User other = ( User ) obj;

215

if ( name == null ) {

216

if ( other.name != null ) return false;

217

} else if ( !name.equals( other.name ) ) return false;

218

return true;

219

}

220

public String toString( ) {

221

StringBuilder sb = new StringBuilder( );

222

sb.append( "UserEntity [ ");

223

sb.append( "administrator = ").append( administrator == null ? "null" : administrator ).append( ", " );

224

sb.append( "enabled = ").append( enabled == null ? "null" : enabled ).append( ", " );

225

sb.append( "name = ").append( name == null ? "null" : name ).append( ", " );

226

sb.append( "password = ").append( password == null ? "null" : password ).append( ", " );

227

sb.append( "queryId = ").append( queryId == null ? "null" : queryId ).append( ", " );

228

sb.append( "secretKey = ").append( secretKey == null ? "null" : secretKey ).append( ", " );

229

sb.append( "token = ").append( token == null ? "null" : token ).append( ", " );

230

sb.append( "certificates = ");

231

for ( X509Cert certificate : getCertificates( ) ) {

232

sb.append( certificate.toString( ) ).append( ", " );

233

}

234

sb.append( "eucaGroupIds = " );

235

for ( String id : eucaGroupIds ) {

236

sb.append( id ).append( ", ");

237

}

238

sb.append( "]");

239

}

240

}

241

242

@Entity

243

@PersistenceContext(name="eucalyptus_auth")

244

@Table(name="auth_x509")

245

@Cache( usage = CacheConcurrencyStrategy.READ_WRITE )

246

public class X509Cert extends AbstractPersistent implements Serializable {

247

@Column( name = "auth_x509_alias", unique=true )

248

String alias

249

@Column( name = "auth_x509_revoked" )

250

Boolean revoked

251

@Lob

252

@Column( name = "auth_x509_pem_certificate" )

253

String pemCertificate

254

public X509Cert(){

255

}

256

public X509Cert( String alias ) {

257

this.alias = alias

258

}

259

public Boolean isRevoked( ) {

260

return this.revoked;

261

}

262

public static X509Cert fromCertificate(X509Certificate x509) {

263

X509Cert x = new X509Cert( );

264

x.setAlias(x509.getSerialNumber( ).toString());

265

x.setPemCertificate( B64.url.encString( PEMFiles.getBytes( x509 ) ) );

266

return x;

267

}

268

public static X509Certificate toCertificate(X509Cert x509) {

269

return PEMFiles.getCert( B64.url.dec( x509.getPemCertificate( ) ) );

270

}

271

272

@Override

273

public int hashCode( ) {

274

final int prime = 31;

275

int result = 1;

276

result = prime * result + ( ( alias == null ) ? 0 : alias.hashCode( ) );

277

return result;

278

}

279

@Override

280

public boolean equals( Object obj ) {

281

if ( this.is( obj ) ) return true;

282

if ( !getClass( ).equals( obj.getClass( ) ) ) return false;

283

X509Cert other = ( X509Cert ) obj;

284

if ( alias == null ) {

285

if ( other.alias != null ) return false;

286

} else if ( !alias.equals( other.alias ) ) return false;

287

return true;

288

}

289

public String toString( ) {

290

return ( new StringBuilder( ) ).append( alias == null ? "null" : alias ).append( " " )

291

.append( revoked == null ? "null" : revoked ).append( " " )

292

.append( pemCertificate == null ? "null" : pemCertificate )

293

.toString( );

294

}

295

}

296

297

@Entity

298

@PersistenceContext(name="eucalyptus_auth")

299

@Table( name = "auth_clusters" )

300

@Cache( usage = CacheConcurrencyStrategy.READ_WRITE )

301

public class ClusterCredentials extends AbstractPersistent implements Serializable {

302

@Column( name = "auth_cluster_name", unique=true )

303

String clusterName

304

@OneToOne( cascade=[CascadeType.ALL], fetch=FetchType.EAGER )

305

@JoinColumn(name="auth_cluster_x509_certificate")

306

@Cache( usage = CacheConcurrencyStrategy.READ_WRITE )

307

X509Cert clusterCertificate

308

@OneToOne( cascade=[CascadeType.ALL], fetch=FetchType.EAGER )

309

@JoinColumn(name="auth_cluster_node_x509_certificate")

310

@Cache( usage = CacheConcurrencyStrategy.READ_WRITE )

311

X509Cert nodeCertificate

312

public ClusterCredentials( ) {

313

}

314

public ClusterCredentials( String clusterName ) {

315

this.clusterName = clusterName;

316

}

317

318

@Override

319

public int hashCode( ) {

320

final int prime = 31;

321

int result = 1;

322

result = prime * result + ( ( clusterName == null ) ? 0 : clusterName.hashCode( ) );

323

return result;

324

}

325

326

@Override

327

public boolean equals( Object obj ) {

328

if ( this.is( obj ) ) return true;

329

if ( !getClass( ).equals( obj.getClass( ) ) ) return false;

330

ClusterCredentials other = ( ClusterCredentials ) obj;

331

if ( clusterName == null ) {

332

if ( other.clusterName != null ) return false;

333

} else if ( !clusterName.equals( other.clusterName ) ) return false;

334

return true;

335

}

336

}

337

Older »